你好,
我想知道是否我的方法來處理三角洲湖是正確的嗎?
1。我第一次使用下麵的命令創建一個三角洲湖。
- > df_json.write.mode(覆蓋).format(“δ”)。保存(delta_silver + json_file_path)
2。我創建一個增量表上麵的位置使用以下命令。
- > deltaTableStore = DeltaTable。forPath(火花,delta_silver + detlta_table1)
3所示。我在這個deltaTableStore執行一些操作,比如我這個三角洲湖合並一些數據幀。
4所示。我的理解是,deltaTableStore.merge()操作將更新數據持久性。我需要回複操作。
請讓我知道我的理解是正確的。