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

インターフェース PartitionPlan

  • すべての既知の実装クラス:
    PartitionPlanImpl
    public interface PartitionPlan
    PartitionPlan は、@PartitionMapper メソッドによって設定されたパーティション処理情報を運ぶヘルパークラスです。PartitionPlan には次のものが含まれます。
    1. パーティションインスタンスの数
    2. パーティションを実行するスレッドの数
    3. 各パーティションの置換プロパティ（#{partitionPlan['propertyName' ]} 構文を使用して参照できます。

    • メソッドのサマリー

      すべてのメソッド   インスタンスメソッド   抽象メソッド  
      修飾子と型 メソッド 説明
      PropertiesSE[]getPartitionProperties()
      パーティションのパーティションプロパティオブジェクトの配列を取得します。
      intgetPartitions()
      パーティションの数を取得します。
      booleangetPartitionsOverride()
      パーティションオーバーライド設定の現在の値を返します。
      intgetThreads()
      このステップでパーティションを実行するために使用するようにリクエストされたスレッドの最大数を取得します。
      voidsetPartitionProperties​(PropertiesSE[] props)
      パーティションのセットの置換プロパティオブジェクトの配列を設定します。
      voidsetPartitions​(int count)
      パーティション数を設定します。
      voidsetPartitionsOverride​(boolean override)
      前回のジョブ実行のパーティション数を上書きするかどうかを指定します。
      voidsetThreads​(int count)
      このステップでパーティションを実行するために使用するようにリクエストされるスレッドの最大数を設定します。

    • メソッドの詳細

      • setPartitions

        void setPartitions​(int count)
        パーティション数を設定します。
        パラメーター:
        count - パーティション数を指定します

      • setPartitionsOverride

        void setPartitionsOverride​(boolean override)
        前回のジョブ実行のパーティション数を上書きするかどうかを指定します。これは、ステップの再起動にのみ適用されます。

        false が指定されている場合、前のジョブ実行からのパーティションカウントが使用され、現在の実行でパーティションカウントに設定された新しい値は無視されます。さらに、前回のジョブ実行のパーティション結果が記憶され、不完全なパーティションのみが再処理されます。

        true が指定されると、現在の実行からのパーティション数が使用され、過去のパーティションからのすべての結果は破棄されます。前回の実行で行われたリソースのクリーンアップまたは作業の取り消しは、アプリケーションの責任です。PartitionReducer アーティファクトの rollbackPartitionedStep メソッドは、パーティションの処理が開始される前に再起動中に呼び出され、クリーンアップフックを提供します。

        パラメーター:
        override - メソッドの説明を参照してください

      • getPartitionsOverride

        boolean getPartitionsOverride()
        パーティションオーバーライド設定の現在の値を返します。
        戻り値:
        設定を上書きします。
        関連事項:
        setPartitionsOverride(boolean)

      • setThreads

        void setThreads​(int count)
        このステップでパーティションを実行するために使用するようにリクエストされるスレッドの最大数を設定します。値 "0" は、パーティション数をスレッド数として使用するようにバッチ実装にリクエストします。この完全な数のスレッドを使用するためにバッチランタイムは必要ないことに注意してください。これほど多くの利用可能なものがない可能性があり、使用量が少ない可能性があります。
        パラメーター:
        count - リクエストされたスレッド数を指定します

      • setPartitionProperties

        void setPartitionProperties​(PropertiesSE[] props)
        パーティションのセットの置換プロパティオブジェクトの配列を設定します。
        パラメーター:
        props - Properties オブジェクト配列を指定します
        関連事項:
        getPartitionProperties()

      • getPartitions

        int getPartitions()
        パーティションの数を取得します。
        戻り値:
        パーティション数

      • getThreads

        int getThreads()
        このステップでパーティションを実行するために使用するようにリクエストされたスレッドの最大数を取得します。値 "0" は、パーティション数をスレッド数として使用するようにバッチ実装にリクエストします。この完全な数のスレッドを使用するためにバッチランタイムは必要ないことに注意してください。これほど多くの利用可能なものがない可能性があり、使用量が少ない可能性があります。
        戻り値:
        リクエストされたスレッド数

      • getPartitionProperties

        PropertiesSE[] getPartitionProperties()
        パーティションのパーティションプロパティオブジェクトの配列を取得します。

        これらは、次の構文の置換式を使用したジョブ XML 置換で使用できます 。#{partitionPlan['propertyName' ]}

        返された Properties 配列の各要素を使用して、単一のパーティションの置換を解決できます。通常の使用例では、各 Properties 要素に同様のプロパティ名のセットがあり、置換によって各パーティションの対応する値に解決される可能性があります。

        戻り値:
        パーティションプロパティオブジェクト配列