クラス SimpleStepBuilder<I,O>
java.lang.ObjectSE
org.springframework.batch.core.step.builder.StepBuilderHelper<B>
org.springframework.batch.core.step.builder.AbstractTaskletStepBuilder<SimpleStepBuilder<I,O>>
org.springframework.batch.core.step.builder.SimpleStepBuilder<I,O>
- 既知の直属サブクラス
FaultTolerantStepBuilder
単純なアイテム処理 (チャンク指向) ステップ用のステップビルダー。項目は、チャンク単位で読み取られてキャッシュされ、その後、すべて同じトランザクション内で処理 (変換) および書き込み (オプションでプロセッサーを省略可能) が行われます。
- 導入:
- 2.2
- 作成者:
- Dave Syer, Mahmoud Ben Hassine, Parikshit Dutta
- 関連事項:
ネストされたクラスのサマリー
クラス org.springframework.batch.core.step.builder.StepBuilderHelper から継承されたネストクラス / インターフェース
StepBuilderHelper.CommonStepProperties
フィールドサマリー
クラス org.springframework.batch.core.step.builder.AbstractTaskletStepBuilder から継承されたフィールド
chunkListeners
クラス org.springframework.batch.core.step.builder.StepBuilderHelper から継承されたフィールド
logger, properties
コンストラクターのサマリー
修飾子コンストラクター説明protected
SimpleStepBuilder
(SimpleStepBuilder<I, O> parent) 親のプロパティで初期化された新しいビルダーを作成します。SimpleStepBuilder
(StepBuilderHelper<?> parent) 親のプロパティで初期化された新しいビルダーを作成します。メソッドのサマリー
修飾子と型メソッド説明build()
提供されるリーダー、ライター、プロセッサーでステップを構築します。chunk
(int chunkSize) このステップのチャンクサイズまたはコミット間隔を設定します。chunk
(CompletionPolicy completionPolicy) チャンク処理の補完ポリシーを設定します。chunkOperations
(RepeatOperations repeatTemplate) chunk size
またはcompletion policy
の代わりに、アイテムリーダーの繰り返しを処理する完全な繰り返し操作インスタンスを提供できます。protected RepeatOperations
protected Tasklet
protected CompletionPolicy
protected int
protected SetSE<StepListener>
protected ItemProcessor<? super I,
? extends O> protected ItemReader<? extends I>
protected ItemWriter<? super O>
protected boolean
アノテーションベースのリスナー構成を使用してオブジェクトを登録します。listener
(ItemProcessListener<? super I, ? super O> listener) アイテムプロセッサーリスナーを登録します。listener
(ItemReadListener<? super I> listener) アイテムリーダーリスナーを登録します。listener
(ItemWriteListener<? super O> listener) アイテムライターリスナーを登録します。processor
(ItemProcessor<? super I, ? extends O> processor) アイテムのストリームを処理または変換するアイテムプロセッサー。reader
(ItemReader<? extends I> reader) アイテムのストリームを提供するアイテムリーダー。リーダーがトランザクション(通常はキュー)であることを示すフラグを設定します。つまり、失敗したアイテムはロールバックされ、後続のトランザクションで再表示される可能性があります。protected void
registerAsStreamsAndListeners
(ItemReader<? extends I> itemReader, ItemProcessor<? super I, ? extends O> itemProcessor, ItemWriter<? super O> itemWriter) protected void
protected SimpleStepBuilder<I,
O> self()
writer
(ItemWriter<? super O> writer) アイテムのチャンクを書き込むアイテムライター。クラス org.springframework.batch.core.step.builder.AbstractTaskletStepBuilder から継承されたメソッド
concurrent, exceptionHandler, getExceptionHandler, getStepOperations, getStreams, getTaskExecutor, getThrottleLimit, getTransactionAttribute, getTransactionManager, listener, registerStepListenerAsChunkListener, stepOperations, stream, taskExecutor, throttleLimit, transactionAttribute, transactionManager
クラス org.springframework.batch.core.step.builder.StepBuilderHelper から継承されたメソッド
allowStartIfComplete, enhance, getJobRepository, getName, isAllowStartIfComplete, listener, meterRegistry, observationConvention, observationRegistry, repository, startLimit
コンストラクターの詳細
SimpleStepBuilder
親のプロパティで初期化された新しいビルダーを作成します。親がコピーされるため、再利用できます。- パラメーター:
parent
- 共通のステッププロパティを含む親ヘルパー
SimpleStepBuilder
親のプロパティで初期化された新しいビルダーを作成します。親がコピーされるため、再利用できます。- パラメーター:
parent
- 共通のステッププロパティを含む親ヘルパー
メソッドの詳細
faultTolerant
build
提供されるリーダー、ライター、プロセッサーでステップを構築します。- オーバーライド:
- クラス
AbstractTaskletStepBuilder<SimpleStepBuilder<I,
のO>> build
- 戻り値:
- 完全に構成され、実行の準備ができているタスクレットステップ
- 関連事項:
registerStepListenerAsItemListener
protected void registerStepListenerAsItemListener()createTasklet
- 次で指定:
- クラス
AbstractTaskletStepBuilder<SimpleStepBuilder<I,
のO>> createTasklet
chunk
このステップのチャンクサイズまたはコミット間隔を設定します。これは、1 回のトランザクションで処理が開始される前に読み取られるアイテムの最大数です。completionPolicy
とは互換性がありません。- パラメーター:
chunkSize
- チャンクサイズ (別名コミット間隔)- 戻り値:
- 流れるようなチェーン用
chunk
チャンク処理の補完ポリシーを設定します。このポリシーがチャンクが完了したと判断するまでアイテムが読み取られ、chunk size
(またはコミット間隔)だけの場合よりも詳細に制御されます。- パラメーター:
completionPolicy
- チャンクの補完ポリシー- 戻り値:
- 流れるようなチェーン用
reader
アイテムのストリームを提供するアイテムリーダー。対応するインターフェースを実装している場合、AbstractTaskletStepBuilder.stream(ItemStream)
またはリスナーとして自動的に登録されます。デフォルトでは非トランザクションと見なされます。- パラメーター:
reader
- アイテムリーダー- 戻り値:
- 流れるようなチェーン用
- 関連事項:
readerTransactionalQueue
writer
アイテムのチャンクを書き込むアイテムライター。対応するインターフェースを実装している場合、AbstractTaskletStepBuilder.stream(ItemStream)
またはリスナーとして自動的に登録されます。- パラメーター:
writer
- アイテムライター- 戻り値:
- 流れるようなチェーン用
processor
アイテムのストリームを処理または変換するアイテムプロセッサー。対応するインターフェースを実装している場合、AbstractTaskletStepBuilder.stream(ItemStream)
またはリスナーとして自動的に登録されます。- パラメーター:
processor
- アイテムプロセッサー- 戻り値:
- 流れるようなチェーン用
readerIsTransactionalQueue
リーダーがトランザクション対応(通常はキュー)であることを示すフラグを設定します。つまり、失敗したアイテムはロールバックされ、後続のトランザクションで再表示される可能性があります。デフォルトは false です。つまり、アイテムはトランザクションの外部で読み取られ、場合によってはキャッシュされます。- 戻り値:
- 流れるようなチェーン用
listener
アノテーションベースのリスナー構成を使用してオブジェクトを登録します。- オーバーライド:
- クラス
AbstractTaskletStepBuilder<SimpleStepBuilder<I,
のO>> listener
- パラメーター:
listener
- リスナーアノテーションで設定されたメソッドを持つオブジェクト- 戻り値:
- 流れるようなチェーン用
listener
アイテムリーダーリスナーを登録します。- パラメーター:
listener
- 登録するリスナー- 戻り値:
- 流れるようなチェーン用
listener
アイテムライターリスナーを登録します。- パラメーター:
listener
- 登録するリスナー- 戻り値:
- 流れるようなチェーン用
listener
アイテムプロセッサーリスナーを登録します。- パラメーター:
listener
- 登録するリスナー- 戻り値:
- 流れるようなチェーン用
chunkOperations
chunk size
またはcompletion policy
の代わりに、アイテムリーダーの繰り返しを処理する完全な繰り返し操作インスタンスを提供できます。- パラメーター:
repeatTemplate
- チャンクの完全な繰り返しテンプレート- 戻り値:
- 流れるようなチェーン用
self
- 次で指定:
- クラス
StepBuilderHelper<SimpleStepBuilder<I,
のO>> self
createChunkOperations
getReader
getWriter
getProcessor
getChunkSize
protected int getChunkSize()isReaderTransactionalQueue
protected boolean isReaderTransactionalQueue()getItemListeners
getChunkCompletionPolicy
- 戻り値:
- チャンクサイズおよび挿入されたポリシー(存在する場合)と一致する
CompletionPolicy
registerAsStreamsAndListeners
protected void registerAsStreamsAndListeners(ItemReader<? extends I> itemReader, ItemProcessor<? super I, ? extends O> itemProcessor, ItemWriter<? super O> itemWriter)