org.apache.flink.runtime.checkpoint

Class CheckpointStatsHistory

java.lang.Object

org.apache.flink.runtime.checkpoint.CheckpointStatsHistory

All Implemented Interfaces:

Serializable

public class CheckpointStatsHistory
extends Object
implements Serializable

An array based history of checkpoint stats.

The size of the array is constrained by the maximum allowed size. The array starts empty an grows with each added checkpoint until it reaches the maximum number of elements. At this point, the elements wrap around and the least recently added entry is overwritten.

Access happens via checkpointsHistory over the statistics and a map that exposes the checkpoint by their ID. Both of these are only guaranteed to reflect the latest state after a call to createSnapshot().

Furthermore the history tracks the latest completed and latest failed checkpoint as well as the latest savepoint.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
AbstractCheckpointStats	getCheckpointById(long checkpointId)
List<AbstractCheckpointStats>	getCheckpoints()
CompletedCheckpointStats	getLatestCompletedCheckpoint()
FailedCheckpointStats	getLatestFailedCheckpoint()
CompletedCheckpointStats	getLatestSavepoint()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getCheckpoints

public List<AbstractCheckpointStats> getCheckpoints()

getCheckpointById

public AbstractCheckpointStats getCheckpointById(long checkpointId)

getLatestCompletedCheckpoint

@Nullable
public CompletedCheckpointStats getLatestCompletedCheckpoint()

getLatestFailedCheckpoint

@Nullable
public FailedCheckpointStats getLatestFailedCheckpoint()

getLatestSavepoint

@Nullable
public CompletedCheckpointStats getLatestSavepoint()