Interface ItemStream

All Known Subinterfaces:
ItemStreamReader<T>, ItemStreamWriter<T>, ResourceAwareItemReaderItemStream<T>, ResourceAwareItemWriterItemStream<T>
All Known Implementing Classes:
AbstractCursorItemReader, AbstractFileItemWriter, AbstractItemCountingItemStreamItemReader, AbstractItemStreamItemReader, AbstractItemStreamItemWriter, AbstractPaginatedDataItemReader, AbstractPagingItemReader, AsyncItemWriter, AvroItemReader, AvroItemWriter, ChunkMessageChannelItemWriter, ChunkMonitor, CompositeItemReader, CompositeItemStream, CompositeItemWriter, FlatFileItemReader, FlatFileItemWriter, ItemStreamSupport, JdbcCursorItemReader, JdbcPagingItemReader, JpaCursorItemReader, JpaPagingItemReader, JsonFileItemWriter, JsonItemReader, KafkaItemReader, LdifReader, MappingLdifReader, MongoCursorItemReader, MongoItemReader, MongoPagingItemReader, MultiResourceItemReader, MultiResourceItemWriter, Neo4jItemReader, RedisItemReader, RepositoryItemReader, ResourcesItemReader, SingleItemPeekableItemReader, StaxEventItemReader, StaxEventItemWriter, StoredProcedureItemReader, SynchronizedItemStreamReader, SynchronizedItemStreamWriter

public interface ItemStream

Marker interface defining a contract for periodically storing state and restoring from that state should an error occur.

Author:
Dave Syer, Lucas Ward, Mahmoud Ben Hassine
  • Method Summary

    Modifier and Type
    Method
    Description
    default void
    If any resources are needed for the stream to operate they need to be destroyed here.
    default void
    open(ExecutionContext executionContext)
    Open the stream for the provided ExecutionContext.
    default void
    update(ExecutionContext executionContext)
    Indicates that the execution context provided during open is about to be saved.