δ表插入-磚社區

[weldermartins]

你好,

我試圖用插入通過三角洲湖後,文檔,但命令不更新或插入新行。

場景:我的源表分離銅層和更新或插入在銀層。

從三角洲。表* deltaTableVendas = DeltaTable進口。forPath(火花,' / user /蜂巢/倉庫/ bronze.db /有賣的)deltaTableVendasUpdates = DeltaTable。forPath(火花,' / user /蜂巢/倉庫/ silver.db /有賣的)dfUpdates = deltaTableVendasUpdates.toDF () deltaTableVendas.alias(有賣)\ .merge (dfUpdates.alias(“更新”),有賣。numero_transacao =更新。numero_transacao”) \ .whenMatchedUpdate(設置= {“numero_transacao”:“更新。numero_transacao”、“numped”:“更新。numped”、“codcli”:“更新。codcli”、“codprod”:“更新。codprod”、“data_venda”:“更新。data_venda”、“quantidade”:“更新。quantidade”、“英勇”:“更新。英勇"})\ .whenNotMatchedInsert(值= {“numero_transacao”:“更新。numero_transacao”、“numped”:“更新。numped”、“codcli”:“更新。codcli”、“codprod”:“更新。codprod", "data_venda": "updates.data_venda", "quantidade": "updates.quantidade", "valor": "updates.valor" } ) \ .execute()

[weldermartins]

@Hubert杜德克,@Werner Stinckens

你知道發生了什麼在這裏?

[werners1]

的實際位置三角洲湖表中的數據嗎?似乎是一個奇怪的地方。

forPath參數預計數據存儲的存儲位置。你點的位置蜂巢存儲元數據。

通常這是類似“/ mnt / datalake /銅/ deltatable”什麼的。

[weldermartins]

你好@Werner Stinckens,甚至改變表Datalake仍然沒有更新。圖片所示的更新並不反映datalake。

[werners1 · Accepted solution]

現在我有點困惑你試圖做什麼。

在你的代碼,你合並從銀銅表數據表(所以青銅表更新),但你銀表的截圖後,不會改變。

這是正常的,因為銅表中的數據更新在您的代碼中。