使改變現有的差值表的數據提要

[yatharthmahesh]

我已經創建了三角洲表,現在我想讓改變數據提要。我讀,我必須設置delta.enableChangeDataFeed財產真實的。但是,這不能使用Scala API。我試著使用這個但是沒有工作。我使用操作係統版本(δ)來執行這些操作。

我真的很感激你能提供的任何幫助。

val ddl_query = " "使用三角洲位置創建表如果不存在delta_training.delta_table ' /用戶/ data-partner-merge / src / main /資源/δ/金剛石/基地”“”“/ /創建表spark.sql (ddl_query)火花。sql (“ALTER TABLE delta_training。onaudience_dpm TBLPROPERTIES(δ。enableChangeDataFeed = true)”),告訴()

由用戶編輯1:如前所述,我試著使用這個,但是仍然沒有改變投入戰鬥。

火花。sql (“ALTER TABLE delta_training。onaudience_dpm TBLPROPERTIES(δ。enableChangeDataFeed = true)”)

[Hubert_Dudek1]

“三角洲。enableChangeDataFeed”必須沒有引號。

火花。sql (“ALTER TABLE delta_training。onaudience_dpm TBLPROPERTIES(δ。enableChangeDataFeed = true)”),告訴()

[yatharthmahesh]

我試過了但這並不工作

[jose_gonzalez]

你可以嚐試在純SQL而不是spark.sql () API ?根據文檔,這是命令:

改變表myDeltaTable集TBLPROPERTIES(δ。enableChangeDataFeed =真正的)

文檔https://docs.m.eheci.com/delta/delta-change-data-feed.html enable-change-data-feed

[Kaniz]

嗨@Yatharth Maheshwari,我們一直沒有收到你最後的回應@Jose岡薩雷斯,我檢查,看看他的建議幫助你。

否則,如果你有任何解決方案,請與社區分享,因為它可以幫助別人。

同時,請別忘了點擊“選擇最佳”按鈕時提供的信息幫助解決你的問題。