是的,你可以GeneratedAlwaysAs三角洲模式中,例如,寫表(δ的注冊表)。
df.write.format(“δ”).mode(附加).saveAsTable(“表”)
更多的例子https://docs.delta.io/latest/delta-batch.html有很多方法來實現這一點
DeltaTable.create(火花)\ .tableName (default.events) \ .addColumn (“eventId”、“長整型數字”)\ .addColumn(“數據”、“字符串”)\ .addColumn (“eventType”、“字符串”)\ .addColumn (“eventTime”、“時間戳”)\ .addColumn(“年”、“INT”generatedAlwaysAs =”(eventTime)”) \ .addColumn(“月”,“INT”, generatedAlwaysAs =月(eventTime)) \ .addColumn(“天”、“INT”, generatedAlwaysAs =“天(eventTime)”) \ .partitionedBy (“eventType”、“年”、“月”、“日”)\ . execute ()
也許嚐試像
df.createOrReplaceTempView (my_table)火花。sql(“創建表的矩形(INT, INT, INT總是生成(a * b));插入矩形(a, b)選擇一個從my_table b)