インターフェース PartitionAnalyzer

すべての既知の実装クラス:
AbstractPartitionAnalyzer

public interface PartitionAnalyzer
PartitionAnalyzer は、各パーティションからデータと最終結果を処理するための制御を受け取ります。ステップで PartitionCollector が構成されている場合、PartitionAnalyzer は、データと結果を処理するための制御をパーティションコレクターから受け取ります。ステップパーティションを処理する各スレッドで個別の PartitionCollector インスタンスが呼び出されますが、単一の PartitionAnalyzer インスタンスは、呼び出されるたびに単一の一貫したスレッドで実行されます。
  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    void
    analyzeCollectorData メソッドは、パーティションコレクターがペイロードを送信するたびに制御を受け取ります。
    void
    analyzeStatus(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 - エラーが発生した場合にスローされます。