Method Detail

• collectPartitionData

  java.io.Serializable collectPartitionData()
                                     throws java.lang.Exception

  The collectPartitionData method receives control periodically during partition processing. This method receives control on each thread processing a partition as follows:

  1. for a chunk type step, it receives control after every chunk checkpoint and then one last time at the end of the partition;
  2. for a batchlet type step, it receives control once at the end of the batchlet.

  Note the collector is not called if the partition terminates due to an unhandled exception.

  Returns:

  an Serializable object to pass to the PartitionAnalyzer.

  Throws:

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