Class CheckpointStatsSnapshot
- java.lang.Object
-
- org.apache.flink.runtime.checkpoint.CheckpointStatsSnapshot
-
- All Implemented Interfaces:
Serializable
public class CheckpointStatsSnapshot extends Object implements Serializable
A snapshot of the checkpoint stats.- See Also:
- Serialized Form
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static CheckpointStatsSnapshot
empty()
CheckpointStatsCounts
getCounts()
Returns the snapshotted checkpoint counts.CheckpointStatsHistory
getHistory()
Returns the snapshotted checkpoint history.RestoredCheckpointStats
getLatestRestoredCheckpoint()
Returns the latest restored checkpoint.CompletedCheckpointStatsSummarySnapshot
getSummaryStats()
Returns the snapshotted completed checkpoint summary stats.
-
-
-
Method Detail
-
empty
public static CheckpointStatsSnapshot empty()
-
getCounts
public CheckpointStatsCounts getCounts()
Returns the snapshotted checkpoint counts.- Returns:
- Snapshotted checkpoint counts.
-
getSummaryStats
public CompletedCheckpointStatsSummarySnapshot getSummaryStats()
Returns the snapshotted completed checkpoint summary stats.- Returns:
- Snapshotted completed checkpoint summary stats.
-
getHistory
public CheckpointStatsHistory getHistory()
Returns the snapshotted checkpoint history.- Returns:
- Snapshotted checkpoint history.
-
getLatestRestoredCheckpoint
@Nullable public RestoredCheckpointStats getLatestRestoredCheckpoint()
Returns the latest restored checkpoint.- Returns:
- Latest restored checkpoint or
null
.
-
-