public class ChunkMonitor extends ItemStreamSupport
ThreadLocal to manage the state and coordinate between the caller
and the wrapped ItemStream.| Modifier and Type | Class and Description |
|---|---|
static class |
ChunkMonitor.ChunkMonitorData |
| Constructor and Description |
|---|
ChunkMonitor() |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
No-op.
|
int |
getOffset() |
void |
incrementOffset() |
void |
open(ExecutionContext executionContext)
No-op.
|
void |
registerItemStream(ItemStream stream) |
void |
resetOffset() |
void |
setChunkSize(int chunkSize) |
void |
setItemReader(ItemReader<?> reader) |
void |
update(ExecutionContext executionContext)
Return empty
ExecutionContext. |
getExecutionContextKey, setExecutionContextName, setNamepublic void registerItemStream(ItemStream stream)
stream - the stream to setpublic void setItemReader(ItemReader<?> reader)
reader - the reader to setpublic void incrementOffset()
public int getOffset()
public void resetOffset()
public void setChunkSize(int chunkSize)
public void close()
throws ItemStreamException
ItemStreamSupportclose in interface ItemStreamclose in class ItemStreamSupportItemStreamExceptionItemStream.close()public void open(ExecutionContext executionContext) throws ItemStreamException
ItemStreamSupportopen in interface ItemStreamopen in class ItemStreamSupportItemStreamExceptionItemStream.open(ExecutionContext)public void update(ExecutionContext executionContext) throws ItemStreamException
ItemStreamSupportExecutionContext.update in interface ItemStreamupdate in class ItemStreamSupportexecutionContext - to be updatedItemStreamExceptionItemStream.update(ExecutionContext)