public class StepFactoryBean<I,O> extends StepParserStepFactoryBean<I,O>
FactoryBean
is used by the JSR-352 namespace parser to create
Step
objects. It stores all of the properties that are
configurable on the <step/>.Constructor and Description |
---|
StepFactoryBean() |
Modifier and Type | Method and Description |
---|---|
protected Step |
createPartitionStep() |
protected TaskletStep |
createTaskletStep() |
protected FaultTolerantStepBuilder<I,O> |
getFaultTolerantStepBuilder(java.lang.String stepName) |
Step |
getObject()
Create a
Step from the configuration provided. |
protected SimpleStepBuilder<I,O> |
getSimpleStepBuilder(java.lang.String stepName) |
void |
setBatchPropertyContext(BatchPropertyContext context) |
protected void |
setChunk(SimpleStepBuilder<I,O> builder) |
void |
setPartitionReducer(javax.batch.api.partition.PartitionReducer reducer) |
void |
setPartitions(int partitions) |
void |
setStepChunkCompletionPolicy(java.lang.Object chunkCompletionPolicy)
Wraps a
CheckpointAlgorithm in a CheckpointAlgorithmAdapter if required for consumption
by the rest of the framework. |
void |
setStepItemProcessor(java.lang.Object itemProcessor)
Wraps a
ItemProcessor in a ItemProcessorAdapter if required for consumption
by the rest of the framework. |
void |
setStepItemReader(java.lang.Object itemReader)
Wraps a
ItemReader in a ItemReaderAdapter if required for consumption
by the rest of the framework. |
void |
setStepItemWriter(java.lang.Object itemWriter)
Wraps a
ItemWriter in a ItemWriterAdapter if required for consumption
by the rest of the framework. |
void |
setStepTasklet(java.lang.Object tasklet)
Wraps a
Batchlet in a BatchletAdapter if required for consumption
by the rest of the framework. |
void |
setTimeout(java.lang.Integer timeout) |
createFaultTolerantStep, createFlowStep, createSimpleStep, enhanceCommonStep, enhanceTaskletStepBuilder, getCommitInterval, getCompletionPolicy, getJobRepository, getName, getObjectType, getPartitionHandler, getStepExecutionAggergator, getTasklet, getTransactionManager, hasChunkElement, hasPartitionElement, hasTasklet, isFaultTolerant, isSingleton, registerItemListeners, requiresTransactionManager, setAllowStartIfComplete, setBackOffPolicy, setBeanName, setCacheCapacity, setChunkCompletionPolicy, setCommitInterval, setFlow, setGridSize, setHasChunkElement, setIsolation, setIsReaderTransactionalQueue, setItemProcessor, setItemReader, setItemWriter, setJob, setJobLauncher, setJobParametersExtractor, setJobRepository, setKeyGenerator, setListeners, setName, setNoRollbackExceptionClasses, setPartitioner, setPartitionHandler, setPartitionLock, setPartitionQueue, setProcessorTransactional, setPropagation, setRetryableExceptionClasses, setRetryContextCache, setRetryLimit, setRetryListeners, setRetryPolicy, setSkipLimit, setSkippableExceptionClasses, setSkipPolicy, setStartLimit, setStep, setStepExecutionAggregator, setStreams, setTaskExecutor, setTasklet, setThrottleLimit, setTransactionManager, setTransactionTimeout, validateFaultTolerantSettings
public void setPartitionReducer(javax.batch.api.partition.PartitionReducer reducer)
public void setBatchPropertyContext(BatchPropertyContext context)
public void setPartitions(int partitions)
public Step getObject() throws java.lang.Exception
Step
from the configuration provided.getObject
in interface org.springframework.beans.factory.FactoryBean<Step>
getObject
in class StepParserStepFactoryBean<I,O>
java.lang.Exception
FactoryBean.getObject()
protected TaskletStep createTaskletStep()
createTaskletStep
in class StepParserStepFactoryBean<I,O>
TaskletStep
protected void setChunk(SimpleStepBuilder<I,O> builder)
setChunk
in class StepParserStepFactoryBean<I,O>
protected Step createPartitionStep()
createPartitionStep
in class StepParserStepFactoryBean<I,O>
public void setStepTasklet(java.lang.Object tasklet)
Batchlet
in a BatchletAdapter
if required for consumption
by the rest of the framework.tasklet
- Tasklet
or Batchlet
implementationjava.lang.IllegalArgumentException
- if tasklet does not implement either Tasklet or Batchletpublic void setStepItemReader(java.lang.Object itemReader)
ItemReader
in a ItemReaderAdapter
if required for consumption
by the rest of the framework.itemReader
- ItemReader
or ItemReader
implementationjava.lang.IllegalArgumentException
- if itemReader does not implement either version of ItemReaderpublic void setStepItemProcessor(java.lang.Object itemProcessor)
ItemProcessor
in a ItemProcessorAdapter
if required for consumption
by the rest of the framework.itemProcessor
- ItemProcessor
or ItemProcessor
implementationjava.lang.IllegalArgumentException
- if itemProcessor does not implement either version of ItemProcessorpublic void setStepItemWriter(java.lang.Object itemWriter)
ItemWriter
in a ItemWriterAdapter
if required for consumption
by the rest of the framework.itemWriter
- ItemWriter
or ItemWriter
implementationjava.lang.IllegalArgumentException
- if itemWriter does not implement either version of ItemWriterpublic void setStepChunkCompletionPolicy(java.lang.Object chunkCompletionPolicy)
CheckpointAlgorithm
in a CheckpointAlgorithmAdapter
if required for consumption
by the rest of the framework.chunkCompletionPolicy
- CompletionPolicy
or CheckpointAlgorithm
implementationjava.lang.IllegalArgumentException
- if chunkCompletionPolicy does not implement either CompletionPolicy or CheckpointAlgorithmprotected FaultTolerantStepBuilder<I,O> getFaultTolerantStepBuilder(java.lang.String stepName)
getFaultTolerantStepBuilder
in class StepParserStepFactoryBean<I,O>
protected SimpleStepBuilder<I,O> getSimpleStepBuilder(java.lang.String stepName)
getSimpleStepBuilder
in class StepParserStepFactoryBean<I,O>
public void setTimeout(java.lang.Integer timeout)