嗨@Tom沙夫納,一個類似的問題。阿州
讀取流將拋出一個異常如果有更新或刪除在你的δ源。這也是清楚的磚文檔:
結構化流不處理不是一個附加的輸入,將拋出一個異常如果發生任何修改在桌子上用作源。
如果你使用IgnoreChanges,真的,它不會拋出異常,但給你更新行+行已經被處理。
這是因為δ表文件級別上發生的一切。
例如,如果您更新一個文件中的一行(大約),以下將會發生:
這也是在文檔中提到的。
忽略變化:處理文檔更新如果源表中的文件必須重寫由於數據更改操作,如更新、合並,刪除(分區),或覆蓋。整個行仍可能被釋放。所以你的下遊消費者應該能夠處理重複……
你必須決定如果這是你的用例。
如果你需要地址更新和刪除具體來說,磚改變數據提要,您可以啟用增量表上。
這給你行級詳細信息插入、添加和刪除(在一些額外存儲的成本和IO)。