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 PartitionAnalyzer
data
- 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 PartitionAnalyzer
batchStatus
- 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.