コンストラクターの詳細

• JsrChunkProcessor

  public JsrChunkProcessor()

• JsrChunkProcessor

  public JsrChunkProcessor(ItemReader<? extends I> reader,
                           ItemProcessor<? super I,? extends O> processor,
                           ItemWriter<? super O> writer,
                           RepeatOperations repeatTemplate)

メソッドの詳細

• getListener

  protected MulticasterBatchListener<I,O> getListener()

• process

  public void process(StepContribution contribution,
                      Chunk<I> chunk)
               throws java.lang.Exception

  チャンクが完了するまで、読み取り（provide(StepContribution, Chunk) を介して）と処理（transform(StepContribution, Object) を介して）をループします。チャンクが完了すると、結果が（persist(StepContribution, Chunk) を介して）書き込まれます。

  次で指定:

  インターフェース ChunkProcessor<I> の process 

  パラメーター:

  contribution - StepContribution

  chunk - Chunk

  例外:

  java.lang.Exception

  関連事項:

  ChunkProcessor.process(StepContribution, Chunk)

• setListeners

  public void setListeners(java.util.List<? extends StepListener> listeners)

  いくつかの StepListener をハンドラーに登録します。それぞれが正しい段階で指定された順序でコールバックを取得します。

  パラメーター:

  listeners - このステップで使用するリスナーのリスト

• registerListener

  public void registerListener(StepListener listener)

  プロセスの適切な段階でコールバックのリスナーを登録します。

  パラメーター:

  listener - StepListener

• provide

  protected I provide(StepContribution contribution,
                      Chunk<I> chunk)
               throws java.lang.Exception

  チャンクループの読み取り部分を担当します。この実装では、doProvide(StepContribution, Chunk) に委譲します

  パラメーター:

  contribution - StepContribution

  chunk - Chunk

  戻り値:

  アイテム

  例外:

  java.lang.Exception - チャンクループの読み取り部分でエラーが発生した場合にスローされます。

• doProvide

  protected final I doProvide(StepContribution contribution,
                              Chunk<I> chunk)
                       throws java.lang.Exception

  読み取りと、必要な関連するリスナー呼び出しを実装します。

  パラメーター:

  contribution - StepContribution

  chunk - Chunk

  戻り値:

  アイテム

  例外:

  java.lang.Exception - 読み取り中またはリスナー呼び出し中にエラーが発生した場合にスローされます。

• transform

  protected O transform(StepContribution contribution,
                        I item)
                 throws java.lang.Exception

  チャンクループの処理部分を担当します。この実装では、プロセッサーが使用可能な場合は doTransform(Object) に委譲します (変更されていない場合は、変更されていないアイテムを返します)

  パラメーター:

  contribution - StepContribution

  item - アイテム

  戻り値:

  プロセッサーが存在する場合は処理済みアイテム (そうでない場合は変更されていないアイテム)

  例外:

  java.lang.Exception - チャンクループの処理部分でエラーが発生した場合にスローされます。

• doTransform

  protected final O doTransform(I item)
                         throws java.lang.Exception

  処理および関連するすべてのリスナー呼び出しを実装します。

  パラメーター:

  item - 処理するアイテム

  戻り値:

  加工品

  例外:

  java.lang.Exception - 処理中にエラーが発生した場合にスローされます。

• persist

  protected void persist(StepContribution contribution,
                         Chunk<O> chunk)
                  throws java.lang.Exception

  チャンクループの書き込み部分を担当します。この実装では、{doPersist(StepContribution, Chunk) に委譲します。

  パラメーター:

  contribution - StepContribution

  chunk - Chunk

  例外:

  java.lang.Exception - チャンクループの書き込み部分でエラーが発生した場合にスローされます。

• doPersist

  protected final void doPersist(StepContribution contribution,
                                 Chunk<O> chunk)
                          throws java.lang.Exception

  書き込みと関連するすべてのリスナー呼び出しを実装します

  パラメーター:

  contribution - StepContribution

  chunk - Chunk

  例外:

  java.lang.Exception - チャンクループの書き込み部分でエラーが発生した場合にスローされます。