Package | Description |
---|---|
org.springframework.batch.core.step.builder | |
org.springframework.batch.core.step.factory | |
org.springframework.batch.core.step.item |
Specific implementations of step concerns for item-oriented approach.
|
org.springframework.batch.core.step.tasklet |
Interfaces and generic implementations of tasklet concerns.
|
org.springframework.batch.item |
Infrastructure interfaces and primary dependencies for item concerns.
|
org.springframework.batch.item.data | |
org.springframework.batch.item.database |
Infrastructure implementations of database based item readers and writers.
|
org.springframework.batch.item.file |
Infrastructure implementations of io file concerns.
|
org.springframework.batch.item.support |
Internal support package
|
org.springframework.batch.item.xml |
Infrastructure implementations of xml input and output.
|
org.springframework.batch.sample.domain.trade.internal |
Modifier and Type | Method and Description |
---|---|
AbstractTaskletStepBuilder<SimpleStepBuilder<I,O>> |
FaultTolerantStepBuilder.stream(ItemStream stream) |
AbstractTaskletStepBuilder<B> |
AbstractTaskletStepBuilder.stream(ItemStream stream)
Register a stream for callbacks that manage restart data.
|
Modifier and Type | Method and Description |
---|---|
void |
SimpleStepFactoryBean.setStreams(ItemStream[] streams)
The streams to inject into the
Step . |
Modifier and Type | Class and Description |
---|---|
class |
ChunkMonitor
Manage the offset data between the last successful commit and updates made to
an input chunk.
|
Modifier and Type | Method and Description |
---|---|
void |
ChunkMonitor.registerItemStream(ItemStream stream) |
Modifier and Type | Method and Description |
---|---|
void |
TaskletStep.registerStream(ItemStream stream)
Register a single
ItemStream for callbacks to the stream
interface. |
void |
TaskletStep.setStreams(ItemStream[] streams)
Register each of the streams for callbacks at the appropriate time in the
step.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ItemStreamReader<T>
Convenience interface that combines
ItemStream and ItemReader
. |
interface |
ItemStreamWriter<T>
Convenience interface that combines
ItemStream and ItemWriter
. |
Modifier and Type | Class and Description |
---|---|
class |
ItemStreamSupport
Empty method implementation of
ItemStream . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractPaginatedDataItemReader<T>
A base class that handles basic reading logic based on the paginated
semantics of Spring Data's paginated facilities.
|
class |
MongoItemReader<T>
Restartable
ItemReader that reads documents from MongoDB
via a paging technique. |
class |
Neo4jItemReader<T>
Restartable
ItemReader that reads objects from the graph database Neo4j
via a paging technique. |
class |
RepositoryItemReader<T>
A
ItemReader that reads records utilizing
a PagingAndSortingRepository . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractCursorItemReader<T>
Abstract base class for any simple item reader that opens a database cursor and continually retrieves
the next row in the ResultSet.
|
class |
AbstractPagingItemReader<T>
Abstract
ItemStreamReader for to extend when
reading database records in a paging fashion. |
class |
HibernateCursorItemReader<T>
ItemStreamReader for reading database records built on top of Hibernate. |
class |
HibernatePagingItemReader<T>
ItemReader for reading database records built on top of Hibernate and
reading only up to a fixed number of items at a time. |
class |
IbatisPagingItemReader<T>
ItemReader for reading database
records using iBATIS in a paging fashion. |
class |
JdbcCursorItemReader<T>
Simple item reader implementation that opens a JDBC cursor and continually retrieves the
next row in the ResultSet.
|
class |
JdbcPagingItemReader<T>
ItemReader for reading database
records using JDBC in a paging fashion. |
class |
JpaPagingItemReader<T>
ItemReader for reading database
records built on top of JPA. |
class |
StoredProcedureItemReader<T>
Item reader implementation that executes a stored procedure and then reads the returned cursor
and continually retrieves the next row in the
ResultSet . |
Modifier and Type | Interface and Description |
---|---|
interface |
ResourceAwareItemReaderItemStream<T>
|
interface |
ResourceAwareItemWriterItemStream<T>
|
Modifier and Type | Class and Description |
---|---|
class |
FlatFileItemReader<T>
Restartable
ItemReader that reads lines from input FlatFileItemReader.setResource(Resource) . |
class |
FlatFileItemWriter<T>
This class is an item writer that writes data to a file or stream.
|
class |
MultiResourceItemReader<T>
Reads items from multiple resources sequentially - resource list is given by
MultiResourceItemReader.setResources(Resource[]) , the
actual reading is delegated to MultiResourceItemReader.setDelegate(ResourceAwareItemReaderItemStream) . |
class |
MultiResourceItemWriter<T>
Wraps a
ResourceAwareItemWriterItemStream and creates a new output
resource when the count of items written in current resource exceeds
MultiResourceItemWriter.setItemCountLimitPerResource(int) . |
class |
ResourcesItemReader
ItemReader which produces Resource instances from an array. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractItemCountingItemStreamItemReader<T>
Abstract superclass for
ItemReader s that supports restart by storing
item count in the ExecutionContext (therefore requires item ordering
to be preserved between runs). |
class |
AbstractItemStreamItemReader<T>
Base class for
ItemReader implementations. |
class |
AbstractItemStreamItemWriter<T>
Base class for
ItemWriter implementations. |
class |
CompositeItemStream
Simple
ItemStream that delegates to a list of other streams. |
class |
CompositeItemWriter<T>
Calls a collection of
ItemWriter s in fixed-order sequence.The implementation is thread-safe if all delegates are thread-safe. |
class |
SingleItemPeekableItemReader<T>
A
PeekableItemReader that allows the user to peek one item ahead. |
Modifier and Type | Method and Description |
---|---|
void |
CompositeItemStream.register(ItemStream stream)
Register a
ItemStream as one of the interesting providers under
the provided key. |
void |
CompositeItemStream.setStreams(ItemStream[] listeners)
Public setter for the listeners.
|
Modifier and Type | Class and Description |
---|---|
class |
StaxEventItemReader<T>
Item reader for reading XML input based on StAX.
|
class |
StaxEventItemWriter<T>
An implementation of
ItemWriter which uses StAX and
Marshaller for serializing object to XML. |
Modifier and Type | Class and Description |
---|---|
class |
TradeWriter
Delegates the actual writing to custom DAO delegate.
|
Copyright © 2014 Pivotal. All rights reserved.