public class CheckpointManager extends Object
Constructor and Description |
---|
CheckpointManager(javax.batch.api.chunk.ItemReader reader,
javax.batch.api.chunk.ItemWriter writer,
javax.batch.api.chunk.CheckpointAlgorithm chkptAlg,
long jobInstanceID,
String stepId,
PersistenceManagerService persistenceManagerService,
DataRepresentationService dataRepresentationService) |
Modifier and Type | Method and Description |
---|---|
boolean |
applyCheckPointPolicy() |
void |
beginCheckpoint() |
int |
checkpointTimeout() |
void |
endCheckpoint() |
Map<CheckpointDataKey,CheckpointData> |
prepareCheckpoints()
Takes the current checkpoint data from the ItemReader and ItemWriter
and store them in the database
|
void |
storeCheckPoints(Map<CheckpointDataKey,CheckpointData> checkpoints) |
public CheckpointManager(javax.batch.api.chunk.ItemReader reader, javax.batch.api.chunk.ItemWriter writer, javax.batch.api.chunk.CheckpointAlgorithm chkptAlg, long jobInstanceID, String stepId, PersistenceManagerService persistenceManagerService, DataRepresentationService dataRepresentationService)
public void beginCheckpoint()
public void endCheckpoint()
public boolean applyCheckPointPolicy()
public Map<CheckpointDataKey,CheckpointData> prepareCheckpoints()
public void storeCheckPoints(Map<CheckpointDataKey,CheckpointData> checkpoints)
public int checkpointTimeout()
Copyright © 2017 The Apache Software Foundation. All rights reserved.