クラス SimpleChunkProvider<I>
java.lang.ObjectSE
org.springframework.batch.core.step.item.SimpleChunkProvider<I>
- 実装されたすべてのインターフェース:
ChunkProvider<I>
- 既知の直属サブクラス
FaultTolerantChunkProvider
ItemReader
から提供する基本的なチャンクを行う ChunkProvider インターフェースの単純な実装。- 作成者:
- Dave Syer, Michael Minella, Mahmoud Ben Hassine
- 関連事項:
フィールドサマリー
修飾子と型フィールド説明protected final ItemReader<? extends I>
protected final org.apache.commons.logging.Log
コンストラクターのサマリー
コンストラクター説明SimpleChunkProvider
(ItemReader<? extends I> itemReader, RepeatOperations repeatOperations) メソッドのサマリー
修飾子と型メソッド説明protected final I
doRead()
読み取りコールバックをリスナーコールバックで囲みます。protected MulticasterBatchListener<I,
?> void
postProcess
(StepContribution contribution, Chunk<I> chunk) provide
(StepContribution contribution) protected I
read
(StepContribution contribution, Chunk<I> chunk) doRead()
へのデリゲート。void
registerListener
(StepListener listener) プロセスの適切な段階でコールバックのリスナーを登録します。void
setListeners
(ListSE<? extends StepListener> listeners) いくつかのStepListener
をハンドラーに登録します。void
setMeterRegistry
(io.micrometer.core.instrument.MeterRegistry meterRegistry) メトリクスに使用するメーターレジストリを設定します。
フィールドの詳細
logger
protected final org.apache.commons.logging.Log loggeritemReader
コンストラクターの詳細
SimpleChunkProvider
メソッドの詳細
setListeners
いくつかのStepListener
をハンドラーに登録します。それぞれが正しい段階で指定された順序でコールバックを取得します。- パラメーター:
listeners
-StepListener
のリスト。
setMeterRegistry
public void setMeterRegistry(io.micrometer.core.instrument.MeterRegistry meterRegistry) メトリクスに使用するメーターレジストリを設定します。- パラメーター:
meterRegistry
- メーター登録- 導入:
- 5.0
registerListener
プロセスの適切な段階でコールバックのリスナーを登録します。- パラメーター:
listener
-StepListener
getListener
- 戻り値:
- リスナー
doRead
読み取りコールバックをリスナーコールバックで囲みます。- 戻り値:
- データソースが使い果たされた場合、アイテムまたは
null
- 例外:
ExceptionSE
- 読み取り中にエラーが発生した場合にスローされます。
provide
- 次で指定:
- インターフェース
ChunkProvider<I>
のprovide
- 例外:
ExceptionSE
postProcess
- 次で指定:
- インターフェース
ChunkProvider<I>
のpostProcess
read
@Nullable protected I read(StepContribution contribution, Chunk<I> chunk) throws SkipOverflowException, ExceptionSE doRead()
へのデリゲート。サブクラスは、追加の動作(例外処理など)を追加できます。- パラメーター:
contribution
- 現在のステップ実行のコントリビュートchunk
- 現在のチャンク- 戻り値:
- 処理用の新しいアイテム、またはデータソースが使い果たされた場合は
null
- 例外:
SkipOverflowException
- 具体的には、チャンクが大量のデータを蓄積し(スキップなど)、強制的にコミットしたい場合。ExceptionSE
- 一般的な課題がある場合