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