メソッドの詳細

• collectPartitionData

  SerializableSE collectPartitionData()
                             throws ExceptionSE

  collectPartitionData メソッドは、パーティション処理中に定期的に制御を受け取ります。このメソッドは、次のようにパーティションを処理する各スレッドで制御を受け取ります。

  1. チャンク型のステップの場合、チャンクチェックポイントごとに制御を受け取り、最後にパーティションの最後にもう一度制御を受け取ります。
  2. バッチレット型のステップの場合、バッチレットの最後に 1 回制御を受け取ります。

  未処理の例外が原因でパーティションが終了した場合、コレクターは呼び出されないことに注意してください。

  戻り値:

  PartitionAnalyzer に渡す Serializable オブジェクト。

  例外:

  ExceptionSE - エラーが発生した場合にスローされます。