寫入

將資料寫入資料來源。

此方法在每個執行器上被呼叫一次,將資料寫入資料來源。 它接受輸入資料的迭代器,並回傳代表提交訊息的單一列,若 None 沒有提交訊息則回傳。

驅動程式會從所有執行者收集提交訊息(若有),並在所有任務成功執行時將其傳達給該 commit() 方法。 若任何任務失敗,將以收集的提交訊息呼叫該 abort() 方法。

新增於 Databricks Runtime 14.3 LTS

語法

write(iterator: Iterator[Row])

參數

參數 類型 說明
iterator 迭代器[列] 輸入資料的迭代器。

退貨

WriterCommitMessage

一個可序列化的提交訊息。