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
修飾子 | コンストラクターと説明 |
---|---|
protected | SimpleStepBuilder(SimpleStepBuilder<I, O> parent) 親のプロパティで初期化された新しいビルダーを作成します。 |
| SimpleStepBuilder(StepBuilderHelper<?> parent) 親のプロパティで初期化された新しいビルダーを作成します。 |
修飾子と型 | メソッドと説明 |
---|---|
TaskletStep | build() 提供されるリーダー、ライター、プロセッサーでステップを構築します。 |
SimpleStepBuilder<I, O> | chunk(CompletionPolicy completionPolicy) チャンク処理の補完ポリシーを設定します。 |
SimpleStepBuilder<I, O> | chunk(int chunkSize) このステップのチャンクサイズまたはコミット間隔を設定します。 |
SimpleStepBuilder<I, O> | chunkOperations(RepeatOperations repeatTemplate) chunk size または completion policy の代わりに、アイテムリーダーの繰り返しを処理する完全な繰り返し操作インスタンスを提供できます。 |
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) アイテムプロセッサーリスナーを登録します。 |
SimpleStepBuilder<I, O> | listener(ItemReadListener<? super I> listener) アイテムリーダーリスナーを登録します。 |
SimpleStepBuilder<I, O> | listener(ItemWriteListener<? super O> listener) アイテムライターリスナーを登録します。 |
SimpleStepBuilder<I, O> | listener(java.lang.Object listener) アノテーションベースのリスナー構成を使用してオブジェクトを登録します。 |
SimpleStepBuilder<I, O> | processor(java.util.function.Function<? super I,? extends O> function) ItemProcessor として委譲される Function 。 |
SimpleStepBuilder<I, O> | processor(ItemProcessor<? super I,? extends O> processor) アイテムのストリームを処理または変換するアイテムプロセッサー。 |
SimpleStepBuilder<I, O> | reader(ItemReader<? extends I> reader) アイテムのストリームを提供するアイテムリーダー。 |
SimpleStepBuilder<I, O> | readerIsTransactionalQueue() リーダーがトランザクション(通常はキュー)であることを示すフラグを設定します。つまり、失敗したアイテムはロールバックされ、後続のトランザクションで再表示される可能性があります。 |
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) アイテムのチャンクを書き込むアイテムライター。 |
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
- 共通のステッププロパティを含む親ヘルパー protected SimpleStepBuilder(SimpleStepBuilder<I,O> parent)
parent
- 共通のステッププロパティを含む親ヘルパー public FaultTolerantStepBuilder<I,O> faultTolerant()
public TaskletStep build()
AbstractTaskletStepBuilder<SimpleStepBuilder<I, O>>
の build
AbstractTaskletStepBuilder.build()
protected void registerStepListenerAsItemListener()
protected Tasklet createTasklet()
AbstractTaskletStepBuilder<SimpleStepBuilder<I, O>>
の createTasklet
public SimpleStepBuilder<I,O> chunk(int chunkSize)
completionPolicy
との互換性はありません。chunkSize
- チャンクサイズ (別名コミット間隔)public SimpleStepBuilder<I,O> chunk(CompletionPolicy completionPolicy)
chunk size
(またはコミット間隔)だけの場合よりも詳細に制御されます。completionPolicy
- チャンクの補完ポリシー public SimpleStepBuilder<I,O> reader(ItemReader<? extends I> reader)
AbstractTaskletStepBuilder.stream(ItemStream)
またはリスナーとして自動的に登録されます。デフォルトでは非トランザクションと見なされます。reader
- アイテムリーダー readerTransactionalQueue
public SimpleStepBuilder<I,O> writer(ItemWriter<? super O> writer)
AbstractTaskletStepBuilder.stream(ItemStream)
またはリスナーとして自動的に登録されます。writer
- アイテムライター public SimpleStepBuilder<I,O> processor(ItemProcessor<? super I,? extends O> processor)
AbstractTaskletStepBuilder.stream(ItemStream)
またはリスナーとして自動的に登録されます。processor
- アイテムプロセッサー public SimpleStepBuilder<I,O> processor(java.util.function.Function<? super I,? extends O> function)
ItemProcessor
として委譲される Function
。これが設定されている場合、processor(ItemProcessor)
を介して構成された ItemProcessor
よりも優先されます。function
- アイテムの処理を委譲する関数 public SimpleStepBuilder<I,O> readerIsTransactionalQueue()
public SimpleStepBuilder<I,O> listener(java.lang.Object listener)
AbstractTaskletStepBuilder<SimpleStepBuilder<I, O>>
の listener
listener
- リスナーアノテーションで設定されたメソッドを持つオブジェクト public SimpleStepBuilder<I,O> listener(ItemReadListener<? super I> listener)
listener
- 登録するリスナー public SimpleStepBuilder<I,O> listener(ItemWriteListener<? super O> listener)
listener
- 登録するリスナー public SimpleStepBuilder<I,O> listener(ItemProcessListener<? super I,? super O> listener)
listener
- 登録するリスナー public SimpleStepBuilder<I,O> chunkOperations(RepeatOperations repeatTemplate)
chunk size
または completion policy
の代わりに、アイテムリーダーの繰り返しを処理する完全な繰り返し操作インスタンスを提供できます。repeatTemplate
- チャンクの完全な繰り返しテンプレート protected 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
protected void registerAsStreamsAndListeners(ItemReader<? extends I> itemReader, ItemProcessor<? super I,? extends O> itemProcessor, ItemWriter<? super O> itemWriter)