Constructor and Description |
---|
KinesisCheckpointState(Duration checkpointInterval,
Clock currentClock) |
Modifier and Type | Method and Description |
---|---|
void |
advanceCheckpoint()
Advance the checkpoint clock by the checkpoint interval.
|
ManualClock |
checkpointClock() |
boolean |
shouldCheckpoint()
Check if it's time to checkpoint based on the current time and the derived time
for the next checkpoint
|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning
public ManualClock checkpointClock()
public boolean shouldCheckpoint()
public void advanceCheckpoint()