public abstract class AbstractCheckpointAlgorithm extends java.lang.Object implements CheckpointAlgorithm
Constructor and Description |
---|
AbstractCheckpointAlgorithm() |
Modifier and Type | Method and Description |
---|---|
void |
beginCheckpoint()
Override this method for the CheckpointAlgorithm
to do something before a checkpoint interval
begins (before the next chunk transaction begins).
|
int |
checkpointTimeout()
Override this method if the CheckpointAlgorithm
establishes a checkpoint timeout.
|
void |
endCheckpoint()
Override this method for the CheckpointAlgorithm
to do something after a checkpoint is taken (after
the chunk transaction is committed).
|
abstract boolean |
isReadyToCheckpoint()
Implement logic in this method
to decide if a checkpoint should be taken now.
|
public int checkpointTimeout() throws java.lang.Exception
checkpointTimeout
in interface CheckpointAlgorithm
java.lang.Exception
- (or subclass) if an error occurs.public void beginCheckpoint() throws java.lang.Exception
beginCheckpoint
in interface CheckpointAlgorithm
java.lang.Exception
- (or subclass) if an error occurs.public abstract boolean isReadyToCheckpoint() throws java.lang.Exception
isReadyToCheckpoint
in interface CheckpointAlgorithm
java.lang.Exception
- (or subclass) if an error occurs.public void endCheckpoint() throws java.lang.Exception
endCheckpoint
in interface CheckpointAlgorithm
java.lang.Exception
- (or subclass) if an error occurs.