类 SimpleChunkProvider<I>

字段详细资料

• logger

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

• itemReader

  protected final ItemReader<? extends I> itemReader

构造器详细资料

• SimpleChunkProvider

  public SimpleChunkProvider​(ItemReader<? extends I> itemReader,
                             RepeatOperations repeatOperations)

方法详细资料

• setListeners

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

  Register some StepListeners with the handler. Each will get the callbacks in the order specified at the correct stage.

  参数:

  listeners - list of StepListeners.

• registerListener

  public void registerListener​(StepListener listener)

  Register a listener for callbacks at the appropriate stages in a process.

  参数:

  listener - a StepListener

• getListener

  protected MulticasterBatchListener<I,​?> getListener()

  返回:

  the listener

• doRead

  @Nullable
  protected final I doRead()
                    throws java.lang.Exception

  Surrounds the read call with listener callbacks.

  返回:

  the item or null if the data source is exhausted

  抛出:

  java.lang.Exception - is thrown if error occurs during read.

• provide

  public Chunk<I> provide​(StepContribution contribution)
                   throws java.lang.Exception

  指定者:

  provide 在接口中 ChunkProvider<I>

  抛出:

  java.lang.Exception

• postProcess

  public void postProcess​(StepContribution contribution,
                          Chunk<I> chunk)

  指定者:

  postProcess 在接口中 ChunkProvider<I>

• read

  @Nullable
  protected I read​(StepContribution contribution,
                   Chunk<I> chunk)
            throws SkipOverflowException,
                   java.lang.Exception

  Delegates to doRead(). Subclasses can add additional behaviour (e.g. exception handling).

  参数:

  contribution - the current step execution contribution

  chunk - the current chunk

  返回:

  a new item for processing or null if the data source is exhausted

  抛出:

  SkipOverflowException - if specifically the chunk is accumulating too much data (e.g. skips) and it wants to force a commit.

  java.lang.Exception - if there is a generic issue