パッケージ org.springframework.batch.core.partition.support

クラス RemoteStepExecutionAggregator

java.lang.ObjectSE
org.springframework.batch.core.partition.support.RemoteStepExecutionAggregator
実装されたすべてのインターフェース:
StepExecutionAggregator, org.springframework.beans.factory.InitializingBean
public class RemoteStepExecutionAggregator extends ObjectSE implements StepExecutionAggregator, org.springframework.beans.factory.InitializingBean
入力がリモートステップからのものである場合に、StepExecution インスタンスのセットを集約するためのコンビニエンスクラス。データはリポジトリからリフレッシュする必要があります。
導入:
2.1
作成者:
Dave Syer

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

    • RemoteStepExecutionAggregator

      public RemoteStepExecutionAggregator()
      新しいインスタンスを作成します（構成の目的で役立ちます）。

    • RemoteStepExecutionAggregator

      public RemoteStepExecutionAggregator(JobExplorer jobExplorer)
      集約時にデータをリフレッシュするために使用できるジョブエクスプローラーを使用して、新しいインスタンスを作成します。
      パラメーター:
      jobExplorer - 使用する JobExplorer

  • メソッドの詳細

    • setJobExplorer

      public void setJobExplorer(JobExplorer jobExplorer)
      パラメーター:
      jobExplorer - 設定する jobExplorer

    • setDelegate

      public void setDelegate(StepExecutionAggregator delegate)
      パラメーター:
      delegate - 設定するデリゲート

    • afterPropertiesSet

      public void afterPropertiesSet() throws ExceptionSE
      次で指定:
      インターフェース org.springframework.beans.factory.InitializingBean の afterPropertiesSet 
      例外:
      ExceptionSE - ジョブエクスプローラーが提供されていない場合

    • aggregate

      public void aggregate(StepExecution result, CollectionSE<StepExecution> executions)
      入力が JobExplorer からリフレッシュされると、入力の実行を結果 StepExecution に集約し、デリゲートアグリゲーターに委譲します。
      次で指定:
      インターフェース StepExecutionAggregator の aggregate 
      パラメーター:
      result - 上書きする結果
      executions - 入力
      関連事項: