クラス FaultTolerantChunkProvider<I>
java.lang.ObjectSE
org.springframework.batch.core.step.item.SimpleChunkProvider<I>
org.springframework.batch.core.step.item.FaultTolerantChunkProvider<I>
- 実装されたすべてのインターフェース:
ChunkProvider<I>
ChunkProvider
インターフェースの FaultTolerant 実装。これにより、読み取りまたは処理中に例外を引き起こすアイテムのスキップまたは再試行が可能になります。フィールドサマリー
クラス org.springframework.batch.core.step.item.SimpleChunkProvider から継承されたフィールド
itemReader, logger
コンストラクターのサマリー
コンストラクター説明FaultTolerantChunkProvider
(ItemReader<? extends I> itemReader, RepeatOperations repeatOperations) メソッドのサマリー
修飾子と型メソッド説明void
postProcess
(StepContribution contribution, Chunk<I> chunk) protected I
read
(StepContribution contribution, Chunk<I> chunk) SimpleChunkProvider.doRead()
へのデリゲート。void
setMaxSkipsOnRead
(int maxSkipsOnRead) void
setRollbackClassifier
(org.springframework.classify.Classifier<ThrowableSE, BooleanSE> rollbackClassifier) 例外が(スキップ可能ではなく)ロールバックなしとしてマークされているかどうかを判別するための分類子。void
setSkipPolicy
(SkipPolicy skipPolicy) 読み取り時に例外をスキップできるかどうかを決定するポリシー。クラス org.springframework.batch.core.step.item.SimpleChunkProvider から継承されたメソッド
doRead, getListener, provide, registerListener, setListeners, setMeterRegistry
フィールドの詳細
DEFAULT_MAX_SKIPS_ON_READ
public static final int DEFAULT_MAX_SKIPS_ON_READ同じチャンク内の読み取りスキップ数のハード制限。チャンクが完了する前にすべてのアイテムがスキップされる暴走ステップでのみ発生するように十分に高くする必要があります(潜在的なヒープメモリの問題につながります)。- 関連事項:
コンストラクターの詳細
FaultTolerantChunkProvider
public FaultTolerantChunkProvider(ItemReader<? extends I> itemReader, RepeatOperations repeatOperations)
メソッドの詳細
setMaxSkipsOnRead
public void setMaxSkipsOnRead(int maxSkipsOnRead) - パラメーター:
maxSkipsOnRead
- 読み取り時のスキップの最大数
setSkipPolicy
読み取り時に例外をスキップできるかどうかを決定するポリシー。- パラメーター:
skipPolicy
- FaultTolerantChunkProvider によって使用されるSkipPolicy
のインスタンス。
setRollbackClassifier
public void setRollbackClassifier(org.springframework.classify.Classifier<ThrowableSE, BooleanSE> rollbackClassifier) 例外が(スキップ可能ではなく)ロールバックなしとしてマークされているかどうかを判別するための分類子。遭遇した場合、スキップ可能でない限り、それらは単に無視されます。- パラメーター:
rollbackClassifier
- 設定するロールバック分類子
read
クラスからコピーされた説明:SimpleChunkProvider
SimpleChunkProvider.doRead()
へのデリゲート。サブクラスは、追加の動作(例外処理など)を追加できます。- オーバーライド:
- クラス
SimpleChunkProvider<I>
のread
- パラメーター:
contribution
- 現在のステップ実行のコントリビュートchunk
- 現在のチャンク- 戻り値:
- 処理用の新しいアイテム、またはデータソースが使い果たされた場合は
null
- 例外:
SkipOverflowException
- 具体的には、チャンクが大量のデータを蓄積し(スキップなど)、強制的にコミットしたい場合。ExceptionSE
- 一般的な課題がある場合
postProcess
- 次で指定:
- インターフェース
ChunkProvider<I>
のpostProcess
- オーバーライド:
- クラス
SimpleChunkProvider<I>
のpostProcess