中止（DataSourceStreamWriter）

タスクの失敗により、このマイクロバッチを中止します。

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

構文

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

パラメーター

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