public class SimpleStepBuilder<I,O> extends AbstractTaskletStepBuilder<SimpleStepBuilder<I,O>>
for a step that handles retry and skip of failed items
StepBuilderHelper.CommonStepProperties
chunkListeners
logger, properties
Modifier | Constructor and Description |
---|---|
protected |
SimpleStepBuilder(SimpleStepBuilder<I,O> parent)
Create a new builder initialized with any properties in the parent.
|
|
SimpleStepBuilder(StepBuilderHelper<?> parent)
Create a new builder initialized with any properties in the parent.
|
Modifier and Type | Method and Description |
---|---|
TaskletStep |
build()
Build a step with the reader, writer, processor as provided.
|
SimpleStepBuilder<I,O> |
chunk(CompletionPolicy completionPolicy)
Sets a completion policy for the chunk processing.
|
SimpleStepBuilder<I,O> |
chunk(int chunkSize)
Sets the chunk size or commit interval for this step.
|
SimpleStepBuilder<I,O> |
chunkOperations(RepeatOperations repeatTemplate)
Instead of a
chunk size or completion policy you can provide
a complete repeat operations instance that handles the iteration over the item reader. |
protected RepeatOperations |
createChunkOperations() |
protected Tasklet |
createTasklet() |
FaultTolerantStepBuilder<I,O> |
faultTolerant() |
protected CompletionPolicy |
getChunkCompletionPolicy() |
protected int |
getChunkSize() |
protected java.util.Set<StepListener> |
getItemListeners() |
protected ItemProcessor<? super I,? extends O> |
getProcessor() |
protected ItemReader<? extends I> |
getReader() |
protected ItemWriter<? super O> |
getWriter() |
protected boolean |
isReaderTransactionalQueue() |
SimpleStepBuilder<I,O> |
listener(ItemProcessListener<? super I,? super O> listener)
Register an item processor listener.
|
SimpleStepBuilder<I,O> |
listener(ItemReadListener<? super I> listener)
Register an item reader listener.
|
SimpleStepBuilder<I,O> |
listener(ItemWriteListener<? super O> listener)
Register an item writer listener.
|
SimpleStepBuilder<I,O> |
listener(java.lang.Object listener)
Registers objects using the annotation based listener configuration.
|
SimpleStepBuilder<I,O> |
processor(java.util.function.Function<? super I,? extends O> function)
A
Function to be delegated to as an ItemProcessor . |
SimpleStepBuilder<I,O> |
processor(ItemProcessor<? super I,? extends O> processor)
An item processor that processes or transforms a stream of items.
|
SimpleStepBuilder<I,O> |
reader(ItemReader<? extends I> reader)
An item reader that provides a stream of items.
|
SimpleStepBuilder<I,O> |
readerIsTransactionalQueue()
Sets a flag to say that the reader is transactional (usually a queue), which is to say that failed items might be
rolled back and re-presented in a subsequent transaction.
|
protected void |
registerAsStreamsAndListeners(ItemReader<? extends I> itemReader,
ItemProcessor<? super I,? extends O> itemProcessor,
ItemWriter<? super O> itemWriter) |
protected void |
registerStepListenerAsItemListener() |
SimpleStepBuilder<I,O> |
writer(ItemWriter<? super O> writer)
An item writer that writes a chunk of items.
|
concurrent, exceptionHandler, getExceptionHandler, getStepOperations, getStreams, getTaskExecutor, getThrottleLimit, getTransactionAttribute, listener, registerStepListenerAsChunkListener, stepOperations, stream, taskExecutor, throttleLimit, transactionAttribute
allowStartIfComplete, enhance, getJobRepository, getName, getTransactionManager, isAllowStartIfComplete, listener, repository, startLimit, transactionManager
public SimpleStepBuilder(StepBuilderHelper<?> parent)
parent
- a parent helper containing common step propertiesprotected SimpleStepBuilder(SimpleStepBuilder<I,O> parent)
parent
- a parent helper containing common step propertiespublic FaultTolerantStepBuilder<I,O> faultTolerant()
public TaskletStep build()
build
in class AbstractTaskletStepBuilder<SimpleStepBuilder<I,O>>
AbstractTaskletStepBuilder.build()
protected void registerStepListenerAsItemListener()
protected Tasklet createTasklet()
createTasklet
in class AbstractTaskletStepBuilder<SimpleStepBuilder<I,O>>
public SimpleStepBuilder<I,O> chunk(int chunkSize)
completionPolicy
.chunkSize
- the chunk size (a.k.a commit interval)public SimpleStepBuilder<I,O> chunk(CompletionPolicy completionPolicy)
chunk size
(or commit interval).completionPolicy
- a completion policy for the chunkpublic SimpleStepBuilder<I,O> reader(ItemReader<? extends I> reader)
AbstractTaskletStepBuilder.stream(ItemStream)
or listener if it implements the corresponding interface. By default assumed to be non-transactional.reader
- an item readerreaderTransactionalQueue
public SimpleStepBuilder<I,O> writer(ItemWriter<? super O> writer)
AbstractTaskletStepBuilder.stream(ItemStream)
or
listener if it implements the corresponding interface.writer
- an item writerpublic SimpleStepBuilder<I,O> processor(ItemProcessor<? super I,? extends O> processor)
AbstractTaskletStepBuilder.stream(ItemStream)
or listener if it implements the corresponding interface.processor
- an item processorpublic SimpleStepBuilder<I,O> processor(java.util.function.Function<? super I,? extends O> function)
Function
to be delegated to as an ItemProcessor
. If this is set,
it will take precedence over any ItemProcessor
configured via
processor(ItemProcessor)
.function
- the function to delegate item processing topublic SimpleStepBuilder<I,O> readerIsTransactionalQueue()
public SimpleStepBuilder<I,O> listener(java.lang.Object listener)
listener
in class AbstractTaskletStepBuilder<SimpleStepBuilder<I,O>>
listener
- the object that has a method configured with listener annotationpublic SimpleStepBuilder<I,O> listener(ItemReadListener<? super I> listener)
listener
- the listener to registerpublic SimpleStepBuilder<I,O> listener(ItemWriteListener<? super O> listener)
listener
- the listener to registerpublic SimpleStepBuilder<I,O> listener(ItemProcessListener<? super I,? super O> listener)
listener
- the listener to registerpublic SimpleStepBuilder<I,O> chunkOperations(RepeatOperations repeatTemplate)
chunk size
or completion policy
you can provide
a complete repeat operations instance that handles the iteration over the item reader.repeatTemplate
- a complete repeat template for the chunkprotected RepeatOperations createChunkOperations()
protected ItemReader<? extends I> getReader()
protected ItemWriter<? super O> getWriter()
protected ItemProcessor<? super I,? extends O> getProcessor()
protected int getChunkSize()
protected boolean isReaderTransactionalQueue()
protected java.util.Set<StepListener> getItemListeners()
protected CompletionPolicy getChunkCompletionPolicy()
CompletionPolicy
consistent with the chunk size and injected policy (if present).protected void registerAsStreamsAndListeners(ItemReader<? extends I> itemReader, ItemProcessor<? super I,? extends O> itemProcessor, ItemWriter<? super O> itemWriter)