类 FaultTolerantChunkProvider<I>

字段详细资料

• DEFAULT_MAX_SKIPS_ON_READ

  public static final int DEFAULT_MAX_SKIPS_ON_READ

  Hard limit for number of read skips in the same chunk. Should be sufficiently high that it is only encountered in a runaway step where all items are skipped before the chunk can complete (leading to a potential heap memory problem).

  另请参阅:

  常量字段值

构造器详细资料

• FaultTolerantChunkProvider

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

方法详细资料

• setMaxSkipsOnRead

  public void setMaxSkipsOnRead​(int maxSkipsOnRead)

  参数:

  maxSkipsOnRead - the maximum number of skips on read

• setSkipPolicy

  public void setSkipPolicy​(SkipPolicy skipPolicy)

  The policy that determines whether exceptions can be skipped on read.

  参数:

  skipPolicy - instance of SkipPolicy to be used by FaultTolerantChunkProvider.

• setRollbackClassifier

  public void setRollbackClassifier​(org.springframework.classify.Classifier<java.lang.Throwable,​java.lang.Boolean> rollbackClassifier)

  Classifier to determine whether exceptions have been marked as no-rollback (as opposed to skippable). If encountered they are simply ignored, unless also skippable.

  参数:

  rollbackClassifier - the rollback classifier to set

• read

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

  从类复制的说明: SimpleChunkProvider
  Delegates to SimpleChunkProvider.doRead(). Subclasses can add additional behaviour (e.g. exception handling).

  覆盖:

  read 在类中 SimpleChunkProvider<I>

  参数:

  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

• postProcess

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

  指定者:

  postProcess 在接口中 ChunkProvider<I>

  覆盖:

  postProcess 在类中 SimpleChunkProvider<I>