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