書き込み（DataSourceStreamWriter）

ストリーミングシンクにデータを書き込みます。

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

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

構文

write(iterator: Iterator[Row])

パラメーター

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

戻り値

WriterCommitMessage

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