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