インターフェース PartitionCollector
public interface PartitionCollector
PartitionCollector は、個々のパーティションからステップの親スレッドで実行されている単一の制御ポイントにデータを渡す方法を提供します。PartitionAnalyzer は、このデータを受信して処理するために使用されます。
メソッドのサマリー
すべてのメソッド インスタンスメソッド 抽象メソッド 修飾子と型 メソッド 説明 SerializableSE
collectPartitionData()
collectPartitionData メソッドは、パーティション処理中に定期的に制御を受け取ります。
メソッドの詳細
collectPartitionData
SerializableSE collectPartitionData() throws ExceptionSE
collectPartitionData メソッドは、パーティション処理中に定期的に制御を受け取ります。このメソッドは、次のようにパーティションを処理する各スレッドで制御を受け取ります。
- チャンク型のステップの場合、チャンクチェックポイントごとに制御を受け取り、最後にパーティションの最後にもう一度制御を受け取ります。
- バッチレット型のステップの場合、バッチレットの最後に 1 回制御を受け取ります。
未処理の例外が原因でパーティションが終了した場合、コレクターは呼び出されないことに注意してください。
- 戻り値:
- PartitionAnalyzer に渡す Serializable オブジェクト。
- 例外:
ExceptionSE
- エラーが発生した場合にスローされます。