public class ItemReaderAdapter<T> extends CheckpointSupport implements ItemReader<T>
ItemReader for use by Spring Batch. All calls are delegated as appropriate
to the corresponding method on the delegate.| Constructor and Description |
|---|
ItemReaderAdapter(javax.batch.api.chunk.ItemReader reader) |
| Modifier and Type | Method and Description |
|---|---|
protected java.io.Serializable |
doCheckpoint()
Used to provide a
Serializable representing the current state of the
batch artifact. |
protected void |
doClose()
Used to close the underlying batch artifact
|
protected void |
doOpen(java.io.Serializable checkpoint)
Used to open a batch artifact with previously saved checkpoint information.
|
T |
read()
Reads a piece of input data and advance to the next one.
|
close, open, updategetExecutionContextKey, setExecutionContextName, setNamepublic ItemReaderAdapter(javax.batch.api.chunk.ItemReader reader)
reader - the ItemReader implementation to delegate topublic T read() throws java.lang.Exception
ItemReadernull at the end of the input
data set. In a transactional setting, caller might get the same item
twice from successive calls (or otherwise), if the first call was in a
transaction that rolled back.read in interface ItemReader<T>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.protected void doClose()
throws java.lang.Exception
CheckpointSupportdoClose in class CheckpointSupportjava.lang.Exceptionprotected java.io.Serializable doCheckpoint()
throws java.lang.Exception
CheckpointSupportSerializable representing the current state of the
batch artifact.doCheckpoint in class CheckpointSupportjava.lang.Exceptionprotected void doOpen(java.io.Serializable checkpoint)
throws java.lang.Exception
CheckpointSupportdoOpen in class CheckpointSupportcheckpoint - previously saved checkpoint objectjava.lang.Exception