Class CheckpointInfo
- java.lang.Object
-
- org.apache.flink.kubernetes.operator.api.status.CheckpointInfo
-
- All Implemented Interfaces:
SnapshotInfo
@Experimental public class CheckpointInfo extends java.lang.Object implements SnapshotInfo
Stores checkpoint-related information.
-
-
Constructor Summary
Constructors Constructor Description CheckpointInfo()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.String
formatErrorMessage(java.lang.Long triggerNonce)
long
getLastPeriodicTriggerTimestamp()
Snapshot
getLastSnapshot()
java.lang.Long
getLastTriggerNonce()
SnapshotTriggerType
getLastTriggerType()
void
resetTrigger()
void
setTrigger(java.lang.String triggerId, SnapshotTriggerType triggerType, CheckpointType formatType)
void
updateLastCheckpoint(Checkpoint checkpoint)
Update last checkpoint info.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.flink.kubernetes.operator.api.status.SnapshotInfo
getTriggerId, getTriggerTimestamp, getTriggerType
-
-
-
-
Method Detail
-
setTrigger
public void setTrigger(java.lang.String triggerId, SnapshotTriggerType triggerType, CheckpointType formatType)
-
resetTrigger
public void resetTrigger()
- Specified by:
resetTrigger
in interfaceSnapshotInfo
-
updateLastCheckpoint
public void updateLastCheckpoint(Checkpoint checkpoint)
Update last checkpoint info.- Parameters:
checkpoint
- Checkpoint to be added.
-
getLastTriggerNonce
public java.lang.Long getLastTriggerNonce()
- Specified by:
getLastTriggerNonce
in interfaceSnapshotInfo
-
getLastPeriodicTriggerTimestamp
public long getLastPeriodicTriggerTimestamp()
- Specified by:
getLastPeriodicTriggerTimestamp
in interfaceSnapshotInfo
-
getLastTriggerType
public SnapshotTriggerType getLastTriggerType()
- Specified by:
getLastTriggerType
in interfaceSnapshotInfo
-
formatErrorMessage
public java.lang.String formatErrorMessage(java.lang.Long triggerNonce)
- Specified by:
formatErrorMessage
in interfaceSnapshotInfo
-
getLastSnapshot
public Snapshot getLastSnapshot()
- Specified by:
getLastSnapshot
in interfaceSnapshotInfo
-
-