書き込み

データ ソースにデータを書き込みます。

このメソッドは、データ ソースにデータを書き込む各 Executor で 1 回呼び出されます。 入力データの反復子を受け取り、コミット メッセージを表す 1 つの行を返します。コミット メッセージがない場合は None します。

ドライバーは、すべての Executor からコミット メッセージ (存在する場合) を収集し、すべてのタスクが正常に実行された場合は commit() メソッドに渡します。 タスクが失敗した場合、 abort() メソッドは収集されたコミット メッセージと共に呼び出されます。

Databricks Runtime 14.3 LTS に追加されました

構文

write(iterator: Iterator[Row])

パラメーター

返品

WriterCommitMessage

シリアル化可能なコミット メッセージ。