コミット メッセージの一覧を使用して、このマイクロバッチをコミットします。
このメソッドは、すべてのタスクが正常に実行されたときにドライバーで呼び出されます。 コミット メッセージは、各タスクから write() メソッド呼び出しから収集され、このメソッドに渡されます。 実装では、コミット メッセージを使用して、ストリーミング シンク内のマイクロバッチをコミットする必要があります。
構文
commit(messages: List[Optional[WriterCommitMessage]], batchId: int)
パラメーター
| パラメーター | タイプ | 説明 |
|---|---|---|
messages |
WriterCommitMessage の一覧 | コミット メッセージの一覧。 書き込みタスクが失敗すると、コミット メッセージが Noneされます。 |
batchId |
int | 書き込まれるデータのバッチを一意に識別する整数。 各マイクロバッチが処理されると、整数は 1 ずつ増加します。 |