public class ChunkMonitor extends ItemStreamSupport
ThreadLocal
を使用して状態を管理し、呼び出し元とラップされた ItemStream
の間の調整を行う必要があるため、シングルスレッドステップでのみ機能します。修飾子と型 | クラスと説明 |
---|---|
static class | ChunkMonitor.ChunkMonitorData |
コンストラクターと説明 |
---|
ChunkMonitor() |
修飾子と型 | メソッドと説明 |
---|---|
void | close() ノーオペレーション。 |
int | getOffset() |
void | incrementOffset() |
void | open(ExecutionContext executionContext) ノーオペレーション。 |
void | registerItemStream(ItemStream stream) |
void | resetOffset() |
void | setChunkSize(int chunkSize) |
void | setItemReader(ItemReader<?> reader) |
void | update(ExecutionContext executionContext) 空の ExecutionContext を返します。 |
getExecutionContextKey, setExecutionContextName, setName
public void registerItemStream(ItemStream stream)
stream
- 設定するストリーム public void setItemReader(ItemReader<?> reader)
reader
- 設定するリーダー public void incrementOffset()
public int getOffset()
public void resetOffset()
public void setChunkSize(int chunkSize)
public void close() throws ItemStreamException
ItemStreamSupport
ItemStream
の close
ItemStreamSupport
の close
ItemStreamException
ItemStream.close()
public void open(ExecutionContext executionContext) throws ItemStreamException
ItemStreamSupport
ItemStream
の open
ItemStreamSupport
の open
executionContext
- 現在のステップの ExecutionContext
再起動時のステップの最後の実行からの executionContext になります。ItemStreamException
ItemStream.open(ExecutionContext)
public void update(ExecutionContext executionContext) throws ItemStreamException
ItemStreamSupport
ExecutionContext
を返します。ItemStream
の update
ItemStreamSupport
の update
executionContext
- 更新される ItemStreamException
ItemStream.update(ExecutionContext)