类 StepFactoryBean<I,O>
- java.lang.Object
- org.springframework.batch.core.configuration.xml.StepParserStepFactoryBean<I,O>
- org.springframework.batch.core.jsr.configuration.xml.StepFactoryBean<I,O>
- 所有已实现的接口:
org.springframework.beans.factory.Aware
,org.springframework.beans.factory.BeanNameAware
,org.springframework.beans.factory.FactoryBean<Step>
public class StepFactoryBean<I,O> extends StepParserStepFactoryBean<I,O>
ThisFactoryBean
is used by the JSR-352 namespace parser to createStep
objects. It stores all of the properties that are configurable on the <step/>.- 从以下版本开始:
- 3.0
- 作者:
- Michael Minella, Chris Schaefer
构造器概要
构造器 构造器 说明 StepFactoryBean()
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 protected Step
createPartitionStep()
protected TaskletStep
createTaskletStep()
protected FaultTolerantStepBuilder<I,O>
getFaultTolerantStepBuilder(java.lang.String stepName)
Step
getObject()
Create aStep
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 aCheckpointAlgorithm
in aCheckpointAlgorithmAdapter
if required for consumption by the rest of the framework.void
setStepItemProcessor(java.lang.Object itemProcessor)
Wraps aItemProcessor
in aItemProcessorAdapter
if required for consumption by the rest of the framework.void
setStepItemReader(java.lang.Object itemReader)
Wraps aItemReader
in aItemReaderAdapter
if required for consumption by the rest of the framework.void
setStepItemWriter(java.lang.Object itemWriter)
Wraps aItemWriter
in aItemWriterAdapter
if required for consumption by the rest of the framework.void
setStepTasklet(java.lang.Object tasklet)
Wraps aBatchlet
in aBatchletAdapter
if required for consumption by the rest of the framework.void
setTimeout(java.lang.Integer timeout)
从类继承的方法 org.springframework.batch.core.configuration.xml.StepParserStepFactoryBean
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
构造器详细资料
StepFactoryBean
public StepFactoryBean()
方法详细资料
setPartitionReducer
public void setPartitionReducer(javax.batch.api.partition.PartitionReducer reducer)
setBatchPropertyContext
public void setBatchPropertyContext(BatchPropertyContext context)
setPartitions
public void setPartitions(int partitions)
getObject
public Step getObject() throws java.lang.Exception
Create aStep
from the configuration provided.- 指定者:
getObject
在接口中org.springframework.beans.factory.FactoryBean<I>
- 覆盖:
getObject
在类中StepParserStepFactoryBean<I,O>
- 抛出:
java.lang.Exception
- 另请参阅:
FactoryBean.getObject()
createTaskletStep
protected TaskletStep createTaskletStep()
- 覆盖:
createTaskletStep
在类中StepParserStepFactoryBean<I,O>
- 返回:
- a new
TaskletStep
setChunk
protected void setChunk(SimpleStepBuilder<I,O> builder)
- 覆盖:
setChunk
在类中StepParserStepFactoryBean<I,O>
createPartitionStep
protected Step createPartitionStep()
- 覆盖:
createPartitionStep
在类中StepParserStepFactoryBean<I,O>
setStepTasklet
public void setStepTasklet(java.lang.Object tasklet)
Wraps aBatchlet
in aBatchletAdapter
if required for consumption by the rest of the framework.- 参数:
tasklet
-Tasklet
orBatchlet
implementation- 抛出:
java.lang.IllegalArgumentException
- if tasklet does not implement either Tasklet or Batchlet
setStepItemReader
public void setStepItemReader(java.lang.Object itemReader)
Wraps aItemReader
in aItemReaderAdapter
if required for consumption by the rest of the framework.- 参数:
itemReader
-ItemReader
orItemReader
implementation- 抛出:
java.lang.IllegalArgumentException
- if itemReader does not implement either version of ItemReader
setStepItemProcessor
public void setStepItemProcessor(java.lang.Object itemProcessor)
Wraps aItemProcessor
in aItemProcessorAdapter
if required for consumption by the rest of the framework.- 参数:
itemProcessor
-ItemProcessor
orItemProcessor
implementation- 抛出:
java.lang.IllegalArgumentException
- if itemProcessor does not implement either version of ItemProcessor
setStepItemWriter
public void setStepItemWriter(java.lang.Object itemWriter)
Wraps aItemWriter
in aItemWriterAdapter
if required for consumption by the rest of the framework.- 参数:
itemWriter
-ItemWriter
orItemWriter
implementation- 抛出:
java.lang.IllegalArgumentException
- if itemWriter does not implement either version of ItemWriter
setStepChunkCompletionPolicy
public void setStepChunkCompletionPolicy(java.lang.Object chunkCompletionPolicy)
Wraps aCheckpointAlgorithm
in aCheckpointAlgorithmAdapter
if required for consumption by the rest of the framework.- 参数:
chunkCompletionPolicy
-CompletionPolicy
orCheckpointAlgorithm
implementation- 抛出:
java.lang.IllegalArgumentException
- if chunkCompletionPolicy does not implement either CompletionPolicy or CheckpointAlgorithm
getFaultTolerantStepBuilder
protected FaultTolerantStepBuilder<I,O> getFaultTolerantStepBuilder(java.lang.String stepName)
getSimpleStepBuilder
protected SimpleStepBuilder<I,O> getSimpleStepBuilder(java.lang.String stepName)
- 覆盖:
getSimpleStepBuilder
在类中StepParserStepFactoryBean<I,O>
setTimeout
public void setTimeout(java.lang.Integer timeout)