パッケージ org.springframework.batch.core.step.builder

クラス PartitionStepBuilder

java.lang.ObjectSE
org.springframework.batch.core.step.builder.StepBuilderHelper<PartitionStepBuilder>
org.springframework.batch.core.step.builder.PartitionStepBuilder
既知の直属サブクラス
RemotePartitioningManagerStepBuilder
public class PartitionStepBuilder extends StepBuilderHelper<PartitionStepBuilder>
PartitionStep インスタンスのステップビルダー。パーティションステップは、（実行コンテキストの形式で）異なる入力パラメーターを使用して同じステップを（場合によってはリモートで）複数回実行します。並列化に役立ちます。
導入:
2.2
作成者:
Dave Syer, Mahmoud Ben Hassine, Dimitrios Liapis

  • コンストラクターの詳細

    • PartitionStepBuilder

      public PartitionStepBuilder(StepBuilderHelper<?> parent)
      親のプロパティで初期化された新しいビルダーを作成します。親がコピーされるため、再利用できます。
      パラメーター:
      parent - 共通のステッププロパティを含む親ヘルパー

  • メソッドの詳細

    • partitioner

      public PartitionStepBuilder partitioner(StringSE workerStepName, Partitioner partitioner)
      StepExecutionSplitter の作成に使用できるパーティショナーを追加します。これまたは明示的な splitter(StepExecutionSplitter) のいずれかを使用しますが、両方は使用しません。
      パラメーター:
      workerStepName - ワーカーステップの名前 (ステップ実行名の作成に使用)
      partitioner - 使用するパーティショナー
      戻り値:
      流れるようなチェーン用

    • step

      public PartitionStepBuilder step(Step step)
      並列実行する実際のステップインスタンスを提供します。明示的な partitionHandler(PartitionHandler) が提供される場合、ステップはオプションであり、構成データ（ステップの名前およびその他の基本プロパティ）を抽出するためにのみ使用されます。
      パラメーター:
      step - 並行して実行するステップ
      戻り値:
      流れるようなチェーン用

    • taskExecutor

      public PartitionStepBuilder taskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
      step(Step) から PartitionHandler を構築するときに使用するタスクエグゼキュータを提供します。主にローカルで並行してステップを実行するために使用されますが、ステップがリモートの場合はリモートで実行するために使用できます。明示的な partitionHandler(PartitionHandler) が提供されている場合は使用されません。
      パラメーター:
      taskExecutor - ステップを並行して実行するときに使用するタスクエグゼキュータ
      戻り値:
      流れるようなチェーン用

    • partitionHandler

      public PartitionStepBuilder partitionHandler(PartitionHandler partitionHandler)
      パーティションステップの作業を実行する明示的なパーティションハンドラーを提供します。パーティションハンドラーは、パーティションステップを特定の分散計算環境に適合させるためのメイン SPI です。ステップインターフェースを介したローカルまたはリモート処理のみが必要な場合はオプション。
      パラメーター:
      partitionHandler - パーティションハンドラー
      戻り値:
      流れるようなチェーン用
      関連事項:

    • gridSize

      public PartitionStepBuilder gridSize(int gridSize)
      必要なステップ実行の数に関する splitter(StepExecutionSplitter) へのヒント。taskExecutor(TaskExecutor) を介してローカルまたはリモートで実行する場合、パーティションのステップ実行の最初の試行でのステップ実行の数を正確に決定します。
      パラメーター:
      gridSize - グリッドサイズ
      戻り値:
      流れるようなチェーン用

    • splitter

      public PartitionStepBuilder splitter(StepExecutionSplitter splitter)
      partitioner(String, Partitioner) から 1 つのビルドを作成する代わりに、明示的な StepExecutionSplitter を提供します。分割をさらに制御する必要がある場合に便利です。
      パラメーター:
      splitter - ステップ実行スプリッター
      戻り値:
      流れるようなチェーン用

    • aggregator

      public PartitionStepBuilder aggregator(StepExecutionAggregator aggregator)
      区分化されたステップ実行を PartitionStep 自体の単一の結果に集約するためのステップ実行アグリゲーターを提供します。デフォルトは、ほとんどの場合に機能する単純な実装です。
      パラメーター:
      aggregator - ステップ実行アグリゲーター
      戻り値:
      流れるようなチェーン用

    • build

      public Step build()

    • self

      protected PartitionStepBuilder self()
      次で指定:
      クラス StepBuilderHelper<PartitionStepBuilder> の self 

    • getTaskExecutor

      protected org.springframework.core.task.TaskExecutor getTaskExecutor()

    • getPartitioner

      protected Partitioner getPartitioner()

    • getStep

      protected Step getStep()

    • getPartitionHandler

      protected PartitionHandler getPartitionHandler()

    • getGridSize

      protected int getGridSize()

    • getSplitter

      protected StepExecutionSplitter getSplitter()

    • getAggregator

      protected StepExecutionAggregator getAggregator()

    • getStepName

      protected StringSE getStepName()