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

クラス SimpleChunkProvider<I>

java.lang.ObjectSE
org.springframework.batch.core.step.item.SimpleChunkProvider<I>
実装されたすべてのインターフェース:
ChunkProvider<I>
既知の直属サブクラス
FaultTolerantChunkProvider
public class SimpleChunkProvider<I> extends ObjectSE implements ChunkProvider<I>
ItemReader から提供する基本的なチャンクを行う ChunkProvider インターフェースの単純な実装。
作成者:
Dave Syer, Michael Minella, Mahmoud Ben Hassine
関連事項:

  • フィールドの詳細

    • logger

      protected final org.apache.commons.logging.Log logger

    • itemReader

      protected final ItemReader<? extends I> itemReader

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

  • メソッドの詳細

    • setListeners

      public void setListeners(ListSE<? extends StepListener> listeners)
      いくつかの StepListener をハンドラーに登録します。それぞれが正しい段階で指定された順序でコールバックを取得します。
      パラメーター:
      listeners - StepListener のリスト。

    • setMeterRegistry

      public void setMeterRegistry(io.micrometer.core.instrument.MeterRegistry meterRegistry)
      メトリクスに使用するメーターレジストリを設定します。
      パラメーター:
      meterRegistry - メーター登録
      導入:
      5.0

    • registerListener

      public void registerListener(StepListener listener)
      プロセスの適切な段階でコールバックのリスナーを登録します。
      パラメーター:
      listener - StepListener

    • getListener

      protected MulticasterBatchListener<I,?> getListener()
      戻り値:
      リスナー

    • doRead

      @Nullable protected final I doRead() throws ExceptionSE
      読み取りコールバックをリスナーコールバックで囲みます。
      戻り値:
      データソースが使い果たされた場合、アイテムまたは null 
      例外:
      ExceptionSE - 読み取り中にエラーが発生した場合にスローされます。

    • provide

      public Chunk<I> provide(StepContribution contribution) throws ExceptionSE
      次で指定:
      インターフェース ChunkProvider<I> の provide 
      例外:
      ExceptionSE

    • postProcess

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

    • read

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