パッケージ org.springframework.batch.core.step.item

クラス FaultTolerantChunkProvider<I>

java.lang.ObjectSE
org.springframework.batch.core.step.item.SimpleChunkProvider<I>
org.springframework.batch.core.step.item.FaultTolerantChunkProvider<I>
実装されたすべてのインターフェース:
ChunkProvider<I>
public class FaultTolerantChunkProvider<I> extends SimpleChunkProvider<I>
ChunkProvider インターフェースの FaultTolerant 実装。これにより、読み取りまたは処理中に例外を引き起こすアイテムのスキップまたは再試行が可能になります。

  • フィールドの詳細

    • DEFAULT_MAX_SKIPS_ON_READ

      public static final int DEFAULT_MAX_SKIPS_ON_READ
      同じチャンク内の読み取りスキップ数のハード制限。チャンクが完了する前にすべてのアイテムがスキップされる暴走ステップでのみ発生するように十分に高くする必要があります（潜在的なヒープメモリの問題につながります）。
      関連事項:

  • コンストラクターの詳細

  • メソッドの詳細

    • setMaxSkipsOnRead

      public void setMaxSkipsOnRead(int maxSkipsOnRead)
      パラメーター:
      maxSkipsOnRead - 読み取り時のスキップの最大数

    • setSkipPolicy

      public void setSkipPolicy(SkipPolicy skipPolicy)
      読み取り時に例外をスキップできるかどうかを決定するポリシー。
      パラメーター:
      skipPolicy - FaultTolerantChunkProvider によって使用される SkipPolicy のインスタンス。

    • setRollbackClassifier

      public void setRollbackClassifier(org.springframework.classify.Classifier<ThrowableSE,BooleanSE> rollbackClassifier)
      例外が（スキップ可能ではなく）ロールバックなしとしてマークされているかどうかを判別するための分類子。遭遇した場合、スキップ可能でない限り、それらは単に無視されます。
      パラメーター:
      rollbackClassifier - 設定するロールバック分類子

    • read

      protected I read(StepContribution contribution, Chunk<I> chunk) throws ExceptionSE
      クラスからコピーされた説明: SimpleChunkProvider
      SimpleChunkProvider.doRead() へのデリゲート。サブクラスは、追加の動作（例外処理など）を追加できます。
      オーバーライド:
      クラス SimpleChunkProvider<I> の read 
      パラメーター:
      contribution - 現在のステップ実行のコントリビュート
      chunk - 現在のチャンク
      戻り値:
      処理用の新しいアイテム、またはデータソースが使い果たされた場合は null 
      例外:
      SkipOverflowException - 具体的には、チャンクが大量のデータを蓄積し（スキップなど）、強制的にコミットしたい場合。
      ExceptionSE - 一般的な課題がある場合

    • postProcess

      public void postProcess(StepContribution contribution, Chunk<I> chunk)
      次で指定:
      インターフェース ChunkProvider<I> の postProcess 
      オーバーライド:
      クラス SimpleChunkProvider<I> の postProcess