Package org.springframework.batch.infrastructure.item.file

Class MultiResourceItemReader<T>

java.lang.Object

org.springframework.batch.infrastructure.item.ItemStreamSupport

org.springframework.batch.infrastructure.item.support.AbstractItemStreamItemReader<T>

org.springframework.batch.infrastructure.item.file.MultiResourceItemReader<T>

All Implemented Interfaces:

ItemReader<T>, ItemStream, ItemStreamReader<T>, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware

public class MultiResourceItemReader<T>
extends AbstractItemStreamItemReader<T>

Reads items from multiple resources sequentially - resource list is given by setResources(Resource[]), the actual reading is delegated to setDelegate(ResourceAwareItemReaderItemStream).

Input resources are ordered using setComparator(Comparator) to make sure resource ordering is preserved between job runs in restart scenario.

Author:

Robert Kasanicky, Lucas Ward, Mahmoud Ben Hassine, Jimmy Praet

Constructor Summary

Constructors

Constructor	Description
MultiResourceItemReader(ResourceAwareItemReaderItemStream<? extends T> delegate)	Create a new MultiResourceItemReader instance with the given delegate.

Method Summary

Modifier and Type	Method	Description
void	close()	Close the setDelegate(ResourceAwareItemReaderItemStream) reader and reset instance variable values.
void	open(ExecutionContext executionContext)	Figure out which resource to start with in case of restart, open the delegate and restore delegate's position in the resource.
@Nullable T	read()	Reads the next item, jumping to next resource if necessary.
void	setComparator(Comparator<org.springframework.core.io.Resource> comparator)
void	setDelegate(ResourceAwareItemReaderItemStream<? extends T> delegate)
void	setResources(org.springframework.core.io.Resource[] resources)
void	setSaveState(boolean saveState)	Set the boolean indicating whether state should be saved in the provided ExecutionContext during the ItemStream call to update.
void	setStrict(boolean strict)	In strict mode the reader will throw an exception on open(ExecutionContext) if there are no resources to read.
void	update(ExecutionContext executionContext)	Store the current resource index and position in the resource.

Methods inherited from class org.springframework.batch.infrastructure.item.ItemStreamSupport

getExecutionContextKey, getName, setBeanName, setExecutionContextName, setName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MultiResourceItemReader

public MultiResourceItemReader(ResourceAwareItemReaderItemStream<? extends T> delegate)

Create a new MultiResourceItemReader instance with the given delegate.

Parameters:

delegate - the delegate ResourceAwareItemReaderItemStream to use

Since:

6.0

Method Details

setStrict

public void setStrict(boolean strict)

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

Parameters:

strict - false by default

read

public @Nullable T read()
                 throws Exception

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

Returns:

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

Throws:

Exception - if an error occurs.

close

public void close()
           throws ItemStreamException

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

Throws:

ItemStreamException

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.

Parameters:

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

Throws:

ItemStreamException

update

public void update(ExecutionContext executionContext)
            throws ItemStreamException

Store the current resource index and position in the resource.

Parameters:

executionContext - to be updated

Throws:

ItemStreamException

setDelegate

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

Parameters:

delegate - reads items from single Resource.

setSaveState

public void setSaveState(boolean saveState)

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

Parameters:

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

setComparator

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

Parameters:

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

setResources

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

Parameters:

resources - input resources