你好,
我有一個情況我現有δ下麵的表的樣子:
現在我有一個與一個額外的列即增量數據。老板:
Dataframe名字- - > scdDF下麵是代碼片段來合並增量Dataframe targetTable,但新列是得不到補充道:
spark.conf.set (“spark.databricks.delta.schema.autoMerge.enabled”,真的)- - >這也是啟用。
但是仍然沒有運氣。下麵是我目前得到的最終結果:
數據是正確的,但唯一的問題是新列即所有者還沒有合並targetTable。
請幫的人。
謝謝!
隻是這一列添加到表的ALTER table語句。你應該抓住每一個與df / dataframe列的表列表。表列,進行比較,如果缺少任何alter table。然後運行您的代碼。