パッケージ org.springframework.batch.core.job.flow.support.state

クラス SplitState

java.lang.ObjectSE
org.springframework.batch.core.job.flow.support.state.AbstractState
org.springframework.batch.core.job.flow.support.state.SplitState
実装されたすべてのインターフェース:
FlowHolder, State
public class SplitState extends AbstractState implements FlowHolder
Flow を複数の並列サブフローに分割する State 実装。
導入:
2.0
作成者:
Dave Syer, Mahmoud Ben Hassine

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

    • SplitState

      public SplitState(CollectionSE<Flow> flows, StringSE name)
      パラメーター:
      flows - Flow インスタンスのコレクション。
      name - 状態の名前。

    • SplitState

      public SplitState(CollectionSE<Flow> flows, StringSE name, @Nullable SplitState parentSplit)
      パラメーター:
      flows - Flow インスタンスのコレクション。
      name - 状態の名前。
      parentSplit - 親 SplitState。

  • メソッドの詳細

    • setTaskExecutor

      public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
      taskExecutor 用のパブリック setter。
      パラメーター:
      taskExecutor - 設定する taskExecutor

    • getFlows

      public CollectionSE<Flow> getFlows()
      次で指定:
      インターフェース FlowHolder の getFlows 
      戻り値:
      流れ

    • handle

      public FlowExecutionStatus handle(FlowExecutor executor) throws ExceptionSE
      フローを TaskExecutor に渡して並行して実行し、すべてが終了するのを待ってから続行します。
      次で指定:
      インターフェース State の handle 
      次で指定:
      クラス AbstractState の handle 
      パラメーター:
      executor - 呼び出し元から渡されたコンテキスト
      戻り値:
      実行のステータス
      例外:
      ExceptionSE - 何かがうまくいかない場合
      関連事項:

    • doAggregation

      protected FlowExecutionStatus doAggregation(CollectionSE<FlowExecution> results, FlowExecutor executor)

    • isEndState

      public boolean isEndState()
      インターフェースからコピーされた説明: State
      State が終了状態かどうかを問い合わせます。処理を続行できる場合、再起動が必要になる場合でも、実装は false を返す必要があります。
      次で指定:
      インターフェース State の isEndState 
      戻り値:
      この State が処理の終わりである場合は true