|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.springframework.batch.core.step.AbstractStep org.springframework.batch.core.partition.support.PartitionStep
public class PartitionStep
Implementation of Step
which partitions the execution and spreads the
load using a PartitionHandler
.
Constructor Summary | |
---|---|
PartitionStep()
|
Method Summary | |
---|---|
void |
afterPropertiesSet()
Assert that mandatory properties are set (stepExecutionSplitter, partitionHandler) and delegate top superclass. |
protected void |
doExecute(StepExecution stepExecution)
Delegate execution to the PartitionHandler provided. |
void |
setPartitionHandler(PartitionHandler partitionHandler)
A PartitionHandler which can send out step executions for remote
processing and bring back the results. |
void |
setStepExecutionAggregator(StepExecutionAggregator stepExecutionAggregator)
A StepExecutionAggregator that can aggregate step executions when
they come back from the handler. |
void |
setStepExecutionSplitter(StepExecutionSplitter stepExecutionSplitter)
Public setter for mandatory property StepExecutionSplitter . |
Methods inherited from class org.springframework.batch.core.step.AbstractStep |
---|
close, execute, getCompositeListener, getJobRepository, getName, getStartLimit, isAllowStartIfComplete, open, registerStepExecutionListener, setAllowStartIfComplete, setBeanName, setJobRepository, setName, setStartLimit, setStepExecutionListeners, toString |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public PartitionStep()
Method Detail |
---|
public void setPartitionHandler(PartitionHandler partitionHandler)
PartitionHandler
which can send out step executions for remote
processing and bring back the results.
partitionHandler
- the PartitionHandler
to setpublic void setStepExecutionAggregator(StepExecutionAggregator stepExecutionAggregator)
StepExecutionAggregator
that can aggregate step executions when
they come back from the handler. Defaults to a
DefaultStepExecutionAggregator
.
stepExecutionAggregator
- the StepExecutionAggregator
to setpublic void setStepExecutionSplitter(StepExecutionSplitter stepExecutionSplitter)
StepExecutionSplitter
.
stepExecutionSplitter
- the StepExecutionSplitter
to setpublic void afterPropertiesSet() throws Exception
afterPropertiesSet
in interface InitializingBean
afterPropertiesSet
in class AbstractStep
Exception
AbstractStep.afterPropertiesSet()
protected void doExecute(StepExecution stepExecution) throws Exception
PartitionHandler
provided. The
StepExecution
passed in here becomes the parent or master
execution for the partition, summarising the status on exit of the
logical grouping of work carried out by the PartitionHandler
. The
individual step executions and their input parameters (through
ExecutionContext
) for the partition elements are provided by the
StepExecutionSplitter
.
doExecute
in class AbstractStep
stepExecution
- the master step execution for the partition
Exception
Step.execute(StepExecution)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |