@thomasthomas
我要做的是使用恢複回滾功能失敗。
這將是這樣工作的:
從pyspark.sql。功能導入馬克斯_max, col tgt_table_name = " catalog.schema。tbl_name“#得到當前表的版本ver_df =(火花。sql (f”描述曆史{tgt_table_name}”) .select (_max(坳(“版本”)).alias(“版本”)))tbl_ver = df.collect () [0]。版本試試:#代碼傳輸數據在這裏除了例外:火花。sql (f”恢複版本表{tgt_table_name} {tbl_ver}”)提高異常(f”{tgt_table_name}失敗的負載。恢複到{tbl_ver}”)
正如我上麵所描述的那樣,我想寫的內容2δ表2 Postgres表的insert語句與火花SQL或Pyspark。
恢複版本/描述語句是有效的語句,當你與三角洲表。否則他們不工作。
@Vidula_Khanna@daniel_sahal
我們還沒有聽到來自你自從上次反應@daniel_sahal,我檢查看看她的建議幫助你。
否則,如果你有任何解決方案,請與社區分享,因為它可以幫助別人。
同時,請別忘了點擊“選擇最佳”按鈕時提供的信息幫助解決你的問題。