类 FaultTolerantChunkProcessor<I,​O>

构造器详细资料

• FaultTolerantChunkProcessor

  public FaultTolerantChunkProcessor​(ItemProcessor<? super I,​? extends O> itemProcessor,
                                     ItemWriter<? super O> itemWriter,
                                     BatchRetryTemplate batchRetryTemplate)

方法详细资料

• setKeyGenerator

  public void setKeyGenerator​(KeyGenerator keyGenerator)

  The KeyGenerator to use to identify failed items across rollback. Not used in the case of the buffering flag being true (the default).

  参数:

  keyGenerator - the KeyGenerator to set

• setProcessSkipPolicy

  public void setProcessSkipPolicy​(SkipPolicy SkipPolicy)

  参数:

  SkipPolicy - the SkipPolicy for item processing

• setWriteSkipPolicy

  public void setWriteSkipPolicy​(SkipPolicy SkipPolicy)

  参数:

  SkipPolicy - the SkipPolicy for item writing

• setRollbackClassifier

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

  A classifier that can distinguish between exceptions that cause rollback (return true) or not (return false).

  参数:

  rollbackClassifier - classifier

• setChunkMonitor

  public void setChunkMonitor​(ChunkMonitor chunkMonitor)

  参数:

  chunkMonitor - monitor

• setBuffering

  public void setBuffering​(boolean buffering)

  A flag to indicate that items have been buffered and therefore will always come back as a chunk after a rollback. Otherwise things are more complicated because after a rollback the new chunk might or might not contain items from the previous failed chunk.

  参数:

  buffering - true if items will be buffered

• setProcessorTransactional

  public void setProcessorTransactional​(boolean processorTransactional)

  Flag to say that the ItemProcessor is transactional (defaults to true). If false then the processor is only called once per item per chunk, even if there are rollbacks with retries and skips.

  参数:

  processorTransactional - the flag value to set

• initializeUserData

  protected void initializeUserData​(Chunk<I> inputs)

  从类复制的说明: SimpleChunkProcessor
  Extension point for subclasses to allow them to memorise the contents of the inputs, in case they are needed for accounting purposes later. The default implementation sets up some user data to remember the original size of the inputs. If this method is overridden then some or all of SimpleChunkProcessor.isComplete(Chunk), SimpleChunkProcessor.getFilterCount(Chunk, Chunk) and SimpleChunkProcessor.getAdjustedOutputs(Chunk, Chunk) might also need to be, to ensure that the user data is handled consistently.

  覆盖:

  initializeUserData 在类中 SimpleChunkProcessor<I,​O>

  参数:

  inputs - the inputs for the process

• getFilterCount

  protected int getFilterCount​(Chunk<I> inputs,
                               Chunk<O> outputs)

  从类复制的说明: SimpleChunkProcessor
  Extension point for subclasses to calculate the filter count. Defaults to the difference between input size and output size.

  覆盖:

  getFilterCount 在类中 SimpleChunkProcessor<I,​O>

  参数:

  inputs - the inputs after transformation

  outputs - the outputs after transformation

  返回:

  the difference in sizes

  另请参阅:

  SimpleChunkProcessor.initializeUserData(Chunk)

• isComplete

  protected boolean isComplete​(Chunk<I> inputs)

  从类复制的说明: SimpleChunkProcessor
  Extension point for subclasses that want to store additional data in the inputs. Default just checks if inputs are empty.

  覆盖:

  isComplete 在类中 SimpleChunkProcessor<I,​O>

  参数:

  inputs - the input chunk

  返回:

  true if it is empty

  另请参阅:

  SimpleChunkProcessor.initializeUserData(Chunk)

• getAdjustedOutputs

  protected Chunk<O> getAdjustedOutputs​(Chunk<I> inputs,
                                        Chunk<O> outputs)

  从类复制的说明: SimpleChunkProcessor
  Extension point for subclasses that want to adjust the outputs based on additional saved data in the inputs. Default implementation just returns the outputs unchanged.

  覆盖:

  getAdjustedOutputs 在类中 SimpleChunkProcessor<I,​O>

  参数:

  inputs - the inputs for the transformation

  outputs - the result of the transformation

  返回:

  the outputs unchanged

  另请参阅:

  SimpleChunkProcessor.initializeUserData(Chunk)

• transform

  protected Chunk<O> transform​(StepContribution contribution,
                               Chunk<I> inputs)
                        throws java.lang.Exception

  覆盖:

  transform 在类中 SimpleChunkProcessor<I,​O>

  抛出:

  java.lang.Exception

• write

  protected void write​(StepContribution contribution,
                       Chunk<I> inputs,
                       Chunk<O> outputs)
                throws java.lang.Exception

  从类复制的说明: SimpleChunkProcessor
  Simple implementation delegates to the SimpleChunkProcessor.doWrite(List) method and increments the write count in the contribution. Subclasses can handle more complicated scenarios, e.g.with fault tolerance. If output items are skipped they should be removed from the inputs as well.

  覆盖:

  write 在类中 SimpleChunkProcessor<I,​O>

  参数:

  contribution - the current step contribution

  inputs - the inputs that gave rise to the outputs

  outputs - the outputs to write

  抛出:

  java.lang.Exception - if there is a problem