public abstract class AbstractPartitionAnalyzer extends java.lang.Object implements PartitionAnalyzer
| Constructor and Description |
|---|
AbstractPartitionAnalyzer() |
| Modifier and Type | Method and Description |
|---|---|
void |
analyzeCollectorData(java.io.Serializable data)
Override this method to analyze PartitionCollector payloads.
|
void |
analyzeStatus(BatchStatus batchStatus,
java.lang.String exitStatus)
Override this method to analyze partition end status.
|
public void analyzeCollectorData(java.io.Serializable data)
throws java.lang.Exception
analyzeCollectorData in interface PartitionAnalyzerdata - specifies the payload sent by the
PartitionCollector.java.lang.Exception - is thrown if an error occurs.public void analyzeStatus(BatchStatus batchStatus, java.lang.String exitStatus) throws java.lang.Exception
analyzeStatus in interface PartitionAnalyzerbatchStatus - specifies the batch status of a partition.exitStatus - specifies the exit status of a partition.java.lang.Exception - is thrown if an error occurs.