インターフェース PartitionCollector


  • public interface PartitionCollector
    PartitionCollector は、個々のパーティションからステップの親スレッドで実行されている単一の制御ポイントにデータを渡す方法を提供します。PartitionAnalyzer は、このデータを受信して処理するために使用されます。
    • メソッドの詳細

      • collectPartitionData

        SerializableSE collectPartitionData()
                                   throws ExceptionSE

        collectPartitionData メソッドは、パーティション処理中に定期的に制御を受け取ります。このメソッドは、次のようにパーティションを処理する各スレッドで制御を受け取ります。

        1. チャンク型のステップの場合、チャンクチェックポイントごとに制御を受け取り、最後にパーティションの最後にもう一度制御を受け取ります。
        2. バッチレット型のステップの場合、バッチレットの最後に 1 回制御を受け取ります。

        未処理の例外が原因でパーティションが終了した場合、コレクターは呼び出されないことに注意してください。

        戻り値:
        PartitionAnalyzer に渡す Serializable オブジェクト。
        例外:
        ExceptionSE - エラーが発生した場合にスローされます。