將資料寫入資料來源。
此方法在每個執行器上被呼叫一次,將資料寫入資料來源。 它接受輸入資料的迭代器,並回傳代表提交訊息的單一列,若 None 沒有提交訊息則回傳。
驅動程式會從所有執行者收集提交訊息(若有),並在所有任務成功執行時將其傳達給該 commit() 方法。 若任何任務失敗,將以收集的提交訊息呼叫該 abort() 方法。
新增於 Databricks Runtime 14.3 LTS
語法
write(iterator: Iterator[Row])
參數
| 參數 | 類型 | 說明 |
|---|---|---|
iterator |
迭代器[列] | 輸入資料的迭代器。 |
退貨
WriterCommitMessage
一個可序列化的提交訊息。