Module jakarta.batch

Package jakarta.batch.api.partition

Interface PartitionAnalyzer

All Known Implementing Classes:

AbstractPartitionAnalyzer

public interface PartitionAnalyzer

PartitionAnalyzer receives control to process data and final results from each partition. If a PartitionCollector is configured on the step, the PartitionAnalyzer receives control to process the data and results from the partition collector. While a separate PartitionCollector instance is invoked on each thread processing a step partition, a single PartitionAnalyzer instance runs on a single, consistent thread each time it is invoked.

Method Summary

Modifier and Type	Method	Description
void	analyzeCollectorData(Serializable data)	The analyzeCollectorData method receives control each time a Partition collector sends its payload.
void	analyzeStatus(BatchStatus batchStatus, String exitStatus)	The analyzeStatus method receives control each time a partition ends.

Method Details

analyzeCollectorData

void analyzeCollectorData(Serializable data)
                   throws Exception

The analyzeCollectorData method receives control each time a Partition collector sends its payload. It receives the Serializable object from the collector as an input.

Parameters:

data - specifies the payload sent by a PartitionCollector.

Throws:

Exception - is thrown if an error occurs.

analyzeStatus

void analyzeStatus(BatchStatus batchStatus,
 String exitStatus)
            throws Exception

The analyzeStatus method receives control each time a partition ends. It receives the batch and exit status strings of the partition as inputs.

Parameters:

batchStatus - specifies the batch status of a partition.

exitStatus - specifies the exit status of a partition.

Throws:

Exception - is thrown if an error occurs.