コミット（DataSourceStreamWriter）

コミット メッセージのリストを使用して、このマイクロバッチをコミットします。

このメソッドは、すべてのタスクが正常に実行されたときにドライバ上で呼び出されます。コミットメッセージは、各タスクのwrite()メソッド呼び出しから収集され、このメソッドに渡されます。実装では、コミットメッセージを使用してストリーミングシンク内のマイクロバッチをコミットする必要があります。

構文

commit(messages: List[Optional[WriterCommitMessage]], batchId: int)

パラメーター

パラメーター	Type	説明
messages	WriterCommitMessage のリスト	コミットメッセージの一覧。書き込みタスクが失敗した場合、コミットメッセージはNoneになります。
batchId	int	書き込まれるデータバッチを一意に識別する整数。処理されるマイクロバッチごとに、整数値は1ずつ増加する。