类 SplitState
- java.lang.Object
- org.springframework.batch.core.job.flow.support.state.AbstractState
- org.springframework.batch.core.job.flow.support.state.SplitState
- 所有已实现的接口:
FlowHolder
,State
- 直接已知子类:
JsrSplitState
public class SplitState extends AbstractState implements FlowHolder
- 从以下版本开始:
- 2.0
- 作者:
- Dave Syer
构造器概要
构造器 构造器 说明 SplitState(java.util.Collection<Flow> flows, java.lang.String name)
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 protected FlowExecutionStatus
doAggregation(java.util.Collection<FlowExecution> results, FlowExecutor executor)
java.util.Collection<Flow>
getFlows()
FlowExecutionStatus
handle(FlowExecutor executor)
Execute the flows in parallel by passing them to theTaskExecutor
and wait for all of them to finish before proceeding.boolean
isEndState()
Inquire as to whether aState
is an end state.void
setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
Public setter for the taskExecutor.从类继承的方法 org.springframework.batch.core.job.flow.support.state.AbstractState
getName, toString
构造器详细资料
SplitState
public SplitState(java.util.Collection<Flow> flows, java.lang.String name)
- 参数:
flows
- collection ofFlow
instances.name
- the name of the state.
方法详细资料
setTaskExecutor
public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
Public setter for the taskExecutor.- 参数:
taskExecutor
- the taskExecutor to set
getFlows
public java.util.Collection<Flow> getFlows()
- 指定者:
getFlows
在接口中FlowHolder
- 返回:
- the flows
handle
public FlowExecutionStatus handle(FlowExecutor executor) throws java.lang.Exception
Execute the flows in parallel by passing them to theTaskExecutor
and wait for all of them to finish before proceeding.- 指定者:
handle
在接口中State
- 指定者:
handle
在类中AbstractState
- 参数:
executor
- the context passed in by the caller- 返回:
- a status for the execution
- 抛出:
java.lang.Exception
- if anything goes wrong- 另请参阅:
State.handle(FlowExecutor)
doAggregation
protected FlowExecutionStatus doAggregation(java.util.Collection<FlowExecution> results, FlowExecutor executor)
isEndState
public boolean isEndState()
从接口复制的说明:State
Inquire as to whether aState
is an end state. Implementations should return false if processing can continue, even if that would require a restart.- 指定者:
isEndState
在接口中State
- 返回:
- true if this
State
is the end of processing