Method Detail

• analyzeCollectorData

  void analyzeCollectorData(java.io.Serializable data)
                     throws java.lang.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:

  java.lang.Exception - is thrown if an error occurs.

• analyzeStatus

  void analyzeStatus(BatchStatus batchStatus,
                     java.lang.String exitStatus)
              throws java.lang.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:

  java.lang.Exception - is thrown if an error occurs.