类 RemoteStepExecutionAggregator
- java.lang.Object
- org.springframework.batch.core.partition.support.RemoteStepExecutionAggregator
- 所有已实现的接口:
StepExecutionAggregator
,org.springframework.beans.factory.InitializingBean
public class RemoteStepExecutionAggregator extends java.lang.Object implements StepExecutionAggregator, org.springframework.beans.factory.InitializingBean
Convenience class for aggregating a set ofStepExecution
instances when the input comes from remote steps, so the data need to be refreshed from the repository.- 从以下版本开始:
- 2.1
- 作者:
- Dave Syer
构造器概要
构造器 构造器 说明 RemoteStepExecutionAggregator()
Create a new instance (useful for configuration purposes).RemoteStepExecutionAggregator(JobExplorer jobExplorer)
Create a new instance with a job explorer that can be used to refresh the data when aggregating.
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 void
afterPropertiesSet()
void
aggregate(StepExecution result, java.util.Collection<StepExecution> executions)
Aggregates the input executions into the resultStepExecution
delegating to the delegate aggregator once the input has been refreshed from theJobExplorer
.void
setDelegate(StepExecutionAggregator delegate)
void
setJobExplorer(JobExplorer jobExplorer)
构造器详细资料
RemoteStepExecutionAggregator
public RemoteStepExecutionAggregator()
Create a new instance (useful for configuration purposes).
RemoteStepExecutionAggregator
public RemoteStepExecutionAggregator(JobExplorer jobExplorer)
Create a new instance with a job explorer that can be used to refresh the data when aggregating.- 参数:
jobExplorer
- theJobExplorer
to use
方法详细资料
setJobExplorer
public void setJobExplorer(JobExplorer jobExplorer)
- 参数:
jobExplorer
- the jobExplorer to set
setDelegate
public void setDelegate(StepExecutionAggregator delegate)
- 参数:
delegate
- the delegate to set
afterPropertiesSet
public void afterPropertiesSet() throws java.lang.Exception
- 指定者:
afterPropertiesSet
在接口中org.springframework.beans.factory.InitializingBean
- 抛出:
java.lang.Exception
- if the job explorer is not provided
aggregate
public void aggregate(StepExecution result, java.util.Collection<StepExecution> executions)
Aggregates the input executions into the resultStepExecution
delegating to the delegate aggregator once the input has been refreshed from theJobExplorer
.- 指定者:
aggregate
在接口中StepExecutionAggregator
- 参数:
result
- the result to overwriteexecutions
- the inputs- 另请参阅:
#aggregate(StepExecution, Collection)