| Modifier and Type | Method and Description |
|---|---|
| public void | analyzeCollectorData(Serializable
specifies the payload sent by a
PartitionCollector. data)The analyzeCollectorData method receives control each time a Partition collector sends its payload. |
| public void | analyzeStatus(BatchStatus
specifies the batch status of a partition. batchStatus, String specifies the exit status of a partition. exitStatus)The analyzeStatus method receives control each time a partition ends. |
| analyzeCollectorData | back to summary |
|---|---|
| public 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.
| |
| analyzeStatus | back to summary |
|---|---|
| public 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.
| |