クラス PartitionPlanImpl

  • 実装されたすべてのインターフェース:
    PartitionPlan

    public class PartitionPlanImpl
    extends ObjectSE
    implements PartitionPlan
    PartitionPlanImpl クラスは、PartitionPlan インターフェースの基本的な実装を提供します。
    • コンストラクターの詳細

      • PartitionPlanImpl

        public PartitionPlanImpl()
    • メソッドの詳細

      • setPartitions

        public void setPartitions​(int count)
        インターフェースからコピーされた説明: PartitionPlan
        パーティション数を設定します。
        次で指定:
        インターフェース PartitionPlansetPartitions 
        パラメーター:
        count - パーティション数を指定します
      • setThreads

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

        public void setPartitionsOverride​(boolean override)
        インターフェースからコピーされた説明: PartitionPlan
        前回のジョブ実行のパーティション数を上書きするかどうかを指定します。これは、ステップの再起動にのみ適用されます。

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

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

        次で指定:
        インターフェース PartitionPlansetPartitionsOverride 
        パラメーター:
        override - メソッドの説明を参照してください
      • getPartitions

        public int getPartitions()
        インターフェースからコピーされた説明: PartitionPlan
        パーティションの数を取得します。
        次で指定:
        インターフェース PartitionPlangetPartitions 
        戻り値:
        パーティション数
      • getThreads

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

        public PropertiesSE[] getPartitionProperties()
        インターフェースからコピーされた説明: PartitionPlan
        パーティションのパーティションプロパティオブジェクトの配列を取得します。

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

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

        次で指定:
        インターフェース PartitionPlangetPartitionProperties 
        戻り値:
        パーティションプロパティオブジェクト配列