public interface CheckpointAlgorithm
Modifier and Type | Method and Description |
---|---|
void |
beginCheckpoint()
The beginCheckpoint method is invoked before the
next checkpoint interval begins (before the next
chunk transaction begins).
|
int |
checkpointTimeout()
The checkpointTimeout is invoked at the beginning of a new
checkpoint interval for the purpose of establishing the checkpoint
timeout.
|
void |
endCheckpoint()
The endCheckpoint method is invoked after the
last checkpoint is taken (after the chunk
transaction is committed).
|
boolean |
isReadyToCheckpoint()
The isReadyToCheckpoint method is invoked by
the batch runtime after each item is processed
to determine if now is the time to checkpoint
the current chunk.
|
int checkpointTimeout() throws java.lang.Exception
java.lang.Exception
- thrown for any errors.void beginCheckpoint() throws java.lang.Exception
java.lang.Exception
- thrown for any errors.boolean isReadyToCheckpoint() throws java.lang.Exception
java.lang.Exception
- thrown for any errors.void endCheckpoint() throws java.lang.Exception
java.lang.Exception
- thrown for any errors.