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