インターフェース PartitionAnalyzer
- すべての既知の実装クラス:
AbstractPartitionAnalyzer
public interface PartitionAnalyzer
PartitionAnalyzer は、各パーティションからデータと最終結果を処理するための制御を受け取ります。ステップで PartitionCollector が構成されている場合、PartitionAnalyzer は、データと結果を処理するための制御をパーティションコレクターから受け取ります。ステップパーティションを処理する各スレッドで個別の PartitionCollector インスタンスが呼び出されますが、単一の PartitionAnalyzer インスタンスは、呼び出されるたびに単一の一貫したスレッドで実行されます。
メソッドのサマリー
修飾子と型メソッド説明void
analyzeCollectorData メソッドは、パーティションコレクターがペイロードを送信するたびに制御を受け取ります。void
analyzeStatus
(BatchStatus batchStatus, StringSE exitStatus) analyzeStatus メソッドは、パーティションが終了するたびに制御を受け取ります。
メソッドの詳細
analyzeCollectorData
analyzeCollectorData メソッドは、パーティションコレクターがペイロードを送信するたびに制御を受け取ります。コレクターから Serializable オブジェクトを入力として受け取ります。- パラメーター:
data
- PartitionCollector によって送信されるペイロードを指定します。- 例外:
ExceptionSE
- エラーが発生した場合にスローされます。
analyzeStatus
analyzeStatus メソッドは、パーティションが終了するたびに制御を受け取ります。パーティションのバッチおよび終了ステータス文字列を入力として受け取ります。- パラメーター:
batchStatus
- パーティションのバッチステータスを指定します。exitStatus
- パーティションの終了ステータスを指定します。- 例外:
ExceptionSE
- エラーが発生した場合にスローされます。