メソッドの詳細

• beginPartitionedStep

  void beginPartitionedStep()
                     throws ExceptionSE

  beginPartitionedStep メソッドは、パーティション処理の開始時に制御を受け取ります。PartitionMapper が呼び出される前、およびパーティションが開始される前に制御を受け取ります。

  例外:

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

• beforePartitionedStepCompletion

  void beforePartitionedStepCompletion()
                                throws ExceptionSE

  beforePartitionedStepCompletion メソッドは、パーティション化されたステップ処理の終了時に制御を受け取ります。すべてのパーティションが完了した後に制御を受け取ります。PartitionReducer がロールバックしている場合は制御を受け取りません。

  例外:

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

• rollbackPartitionedStep

  void rollbackPartitionedStep()
                        throws ExceptionSE

  rollbackPartitionedStep メソッドは、ランタイムがパーティション化されたステップをロールバックしている場合に制御を受け取ります。まだ実行中のパーティションスレッドは、このメソッドが呼び出される前に完了できます。このメソッドは、次の条件のいずれかが当てはまる場合に制御を受け取ります。

  1. 1 つ以上のパーティションは、バッチステータスが STOPPED または FAILED で終了します。
  2. 次のパーティション化されたステップコールバックのいずれかが例外をスローします。
     PartitionMapper
     PartitionReducer
     PartitionCollector
     PartitionAnalyzer
  3. ステップが分割されたジョブが再開されます。

  例外:

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

• afterPartitionedStepCompletion

  void afterPartitionedStepCompletion(PartitionReducer.PartitionStatus status)
                               throws ExceptionSE

  afterPartitionedStepCompletion メソッドは、パーティション処理の終了時に制御を受け取ります。パーティション処理の結果を識別するステータス値を受け取ります。ステータス文字列の値は、"COMMIT" または "ROLLBACK" のいずれかです。

  パラメーター:

  status - 分割されたステップの結果を指定します。値は "COMMIT" または "ROLLBACK" です。

  例外:

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