パッケージ jakarta.batch.api.partition

インターフェース PartitionReducer

  • すべての既知の実装クラス:
    AbstractPartitionReducer
    public interface PartitionReducer
    PartitionReducer は、パーティション間で作業単位の境界を提供します。これは JTA トランザクションではありません。リソースは参加していません。むしろ、マージまたは補正ロジックのファイナライズを容易にするトランザクションフローセマンティクスを提供します。

    • メソッドの詳細

      • 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 - エラーが発生した場合にスローされます。