書く

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

このメソッドは、データをデータソースに書き込むために各エグゼキューターで 1 回呼び出されます。 入力データのイテレータを受け取り、コミットメッセージを表す単一の行を返します。コミットメッセージがない場合はNone返します。

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

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

構文

write(iterator: Iterator[Row])

パラメーター

パラメーター	Type	説明
iterator	イテレータ[行]	入力データのイテレータ。

戻り値

WriterCommitMessage

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