类 MultiResourceItemReader<T>

构造器详细资料

• MultiResourceItemReader

  public MultiResourceItemReader()

方法详细资料

• setStrict

  public void setStrict​(boolean strict)

  In strict mode the reader will throw an exception on open(org.springframework.batch.item.ExecutionContext) if there are no resources to read.

  参数:

  strict - false by default

• read

  public T read()
         throws java.lang.Exception,
                UnexpectedInputException,
                ParseException

  Reads the next item, jumping to next resource if necessary.

  返回:

  T the item to be processed or null if the data source is exhausted

  抛出:

  ParseException - if there is a problem parsing the current record (but the next one may still be valid)

  NonTransientResourceException - if there is a fatal exception in the underlying resource. After throwing this exception implementations should endeavour to return null from subsequent calls to read.

  UnexpectedInputException - if there is an uncategorised problem with the input data. Assume potentially transient, so subsequent calls to read might succeed.

  java.lang.Exception - if an there is a non-specific error.

• close

  public void close()
             throws ItemStreamException

  Close the setDelegate(ResourceAwareItemReaderItemStream) reader and reset instance variable values.

  指定者:

  close 在接口中 ItemStream

  覆盖:

  close 在类中 ItemStreamSupport

  抛出:

  ItemStreamException

  另请参阅:

  ItemStream.close()

• open

  public void open​(ExecutionContext executionContext)
            throws ItemStreamException

  Figure out which resource to start with in case of restart, open the delegate and restore delegate's position in the resource.

  指定者:

  open 在接口中 ItemStream

  覆盖:

  open 在类中 ItemStreamSupport

  参数:

  executionContext - current step's ExecutionContext. Will be the executionContext from the last run of the step on a restart.

  抛出:

  ItemStreamException

  另请参阅:

  ItemStream.open(ExecutionContext)

• update

  public void update​(ExecutionContext executionContext)
              throws ItemStreamException

  Store the current resource index and position in the resource.

  指定者:

  update 在接口中 ItemStream

  覆盖:

  update 在类中 ItemStreamSupport

  参数:

  executionContext - to be updated

  抛出:

  ItemStreamException

  另请参阅:

  ItemStream.update(ExecutionContext)

• setDelegate

  public void setDelegate​(ResourceAwareItemReaderItemStream<? extends T> delegate)

  参数:

  delegate - reads items from single Resource.

• setSaveState

  public void setSaveState​(boolean saveState)

  Set the boolean indicating whether or not state should be saved in the provided ExecutionContext during the ItemStream call to update.

  参数:

  saveState - true to update ExecutionContext. False do not update ExecutionContext.

• setComparator

  public void setComparator​(java.util.Comparator<org.springframework.core.io.Resource> comparator)

  参数:

  comparator - used to order the injected resources, by default compares Resource.getFilename() values.

• setResources

  public void setResources​(org.springframework.core.io.Resource[] resources)

  参数:

  resources - input resources

• getCurrentResource

  @Nullable
  public org.springframework.core.io.Resource getCurrentResource()

  Getter for the current resource.

  返回:

  the current resource or null if all resources have been processed or the first resource has not been assigned yet.