public class ChunkMonitor
extends org.springframework.batch.item.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() |
int |
getOffset() |
void |
incrementOffset() |
void |
open(org.springframework.batch.item.ExecutionContext executionContext) |
void |
registerItemStream(org.springframework.batch.item.ItemStream stream) |
void |
resetOffset() |
void |
setChunkSize(int chunkSize) |
void |
setItemReader(org.springframework.batch.item.ItemReader<?> reader) |
void |
update(org.springframework.batch.item.ExecutionContext executionContext) |
public void registerItemStream(org.springframework.batch.item.ItemStream stream)
stream - the stream to setpublic void setItemReader(org.springframework.batch.item.ItemReader<?> reader)
reader - the reader to setpublic void incrementOffset()
public int getOffset()
public void resetOffset()
public void setChunkSize(int chunkSize)
public void close()
throws org.springframework.batch.item.ItemStreamException
close in interface org.springframework.batch.item.ItemStreamclose in class org.springframework.batch.item.ItemStreamSupportorg.springframework.batch.item.ItemStreamExceptionpublic void open(org.springframework.batch.item.ExecutionContext executionContext)
throws org.springframework.batch.item.ItemStreamException
open in interface org.springframework.batch.item.ItemStreamopen in class org.springframework.batch.item.ItemStreamSupportorg.springframework.batch.item.ItemStreamExceptionpublic void update(org.springframework.batch.item.ExecutionContext executionContext)
throws org.springframework.batch.item.ItemStreamException
update in interface org.springframework.batch.item.ItemStreamupdate in class org.springframework.batch.item.ItemStreamSupportorg.springframework.batch.item.ItemStreamException