Package jakarta.batch.api.partition
Interface PartitionCollector
-
public interface PartitionCollector
PartitionCollector provides a way to pass data from individual partitions to a single point of control running on the step's parent thread. The PartitionAnalyzer is used to receive and process this data.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Serializable
collectPartitionData()
The collectPartitionData method receives control periodically during partition processing.
-
-
-
Method Detail
-
collectPartitionData
Serializable collectPartitionData() throws Exception
The collectPartitionData method receives control periodically during partition processing. This method receives control on each thread processing a partition as follows:
- for a chunk type step, it receives control after every chunk checkpoint and then one last time at the end of the partition;
- for a batchlet type step, it receives control once at the end of the batchlet.
Note the collector is not called if the partition terminates due to an unhandled exception.
- Returns:
- an Serializable object to pass to the PartitionAnalyzer.
- Throws:
Exception
- is thrown if an error occurs.
-
-