01-12-2022上午11點
考慮我們有兩個表A和B。
qry = " "
插入表一
Select *從表B Id是空的地方
”“”
spark.sql (qry)
我需要的數量記錄插入後運行該磚。
01-13-202205:46我
你好,
我的要求是我將創建一個函數使用Python代碼執行插入操作差值表,這就是為什麼我在運行它Python細胞。
我將傳遞一個表名,功能和我需要的數量記錄插入到表一旦執行函數。
所以任何解決方案實現呢?
01-14-2022上午02:52
@@ROWCOUNT,而t - SQL函數不是火花SQL。我還沒找到這樣的文檔但有其他方式每個插入無論如何返回num_affected_rows和num_inserted_rows字段。
例如可以使用
df.first () (“num_inserted_rows”)
或子查詢並選擇在sql語法。
我包括截圖示例。
01-14-202206:21我
嗨@Hubert杜德克
你的方法是為我工作。
謝謝你!
01-14-202206:54我
太棒了!請當你可以選擇最佳答案。
06-14-202303:38點
@Hubert杜德克,當我執行一個類似的代碼通過databricks-connect VSCode執行,dataframe包含1行沒有列,這是一個問題。執行相同的代碼在一個筆記本在同一集群工作正如你所說。這可能是一個錯誤在databricks-connect嗎?
從未顯出
加入我們的快速增長的數據專業人員和專家的80 k +社區成員,準備發現,幫助和合作而做出有意義的聯係。
點擊在這裏注冊今天,加入!
參與令人興奮的技術討論,加入一個組與你的同事和滿足我們的成員。