Package javax.batch.api.chunk
Interface CheckpointAlgorithm
-
- All Known Implementing Classes:
AbstractCheckpointAlgorithm
public interface CheckpointAlgorithmCheckpointAlgorithm provides a custom checkpoint policy for chunk steps.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidbeginCheckpoint()The beginCheckpoint method is invoked before the next checkpoint interval begins.intcheckpointTimeout()The checkpointTimeout is invoked at the beginning of a new checkpoint interval for the purpose of establishing the checkpoint timeout.voidendCheckpoint()The endCheckpoint method is invoked after the current checkpoint ends.booleanisReadyToCheckpoint()The isReadyToCheckpoint method is invoked by the batch runtime after each item processed to determine if now is the time to checkpoint the current chunk.
-
-
-
Method Detail
-
checkpointTimeout
int checkpointTimeout() throws java.lang.ExceptionThe checkpointTimeout is invoked at the beginning of a new checkpoint interval for the purpose of establishing the checkpoint timeout. It is invoked before the next checkpoint transaction begins. This method returns an integer value, which is the timeout value that will be used for the next checkpoint transaction. This method is useful to automate the setting of the checkpoint timeout based on factors known outside the job definition.- Returns:
- the timeout interval to use for the next checkpoint interval
- Throws:
java.lang.Exception- thrown for any errors.
-
beginCheckpoint
void beginCheckpoint() throws java.lang.ExceptionThe beginCheckpoint method is invoked before the next checkpoint interval begins.- Throws:
java.lang.Exception- thrown for any errors.
-
isReadyToCheckpoint
boolean isReadyToCheckpoint() throws java.lang.ExceptionThe isReadyToCheckpoint method is invoked by the batch runtime after each item processed to determine if now is the time to checkpoint the current chunk.- Returns:
- boolean indicating whether or not to checkpoint now.
- Throws:
java.lang.Exception- thrown for any errors.
-
endCheckpoint
void endCheckpoint() throws java.lang.ExceptionThe endCheckpoint method is invoked after the current checkpoint ends.- Throws:
java.lang.Exception- thrown for any errors.
-
-