程序包 org.springframework.batch.sample.domain.multiline

类 AggregateItemReader<T>

  • 所有已实现的接口:
    ItemReader<java.util.List<T>>
    public class AggregateItemReader<T>
extends java.lang.Object
implements ItemReader<java.util.List<T>>
    An ItemReader that delivers a list as its item, storing up objects from the injected ItemReader until they are ready to be packed out as a collection. This class must be used as a wrapper for a custom ItemReader that can identify the record boundaries. The custom reader should mark the beginning and end of records by returning an AggregateItem which responds true to its query methods is*().

    This class is thread-safe (it can be used concurrently by multiple threads) as long as the ItemReader is also thread-safe.
    作者:
    Dave Syer
    另请参阅:
    AggregateItem.isHeader(), AggregateItem.isFooter()

    • 方法详细资料

      • read

        public java.util.List<T> read()
                       throws java.lang.Exception
        Get the next list of records.
        指定者:
        read 在接口中 ItemReader<T>
        返回:
        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.
        另请参阅:
        ItemReader.read()