org.apache.flink.runtime.checkpoint

Class CheckpointStatsTracker

java.lang.Object

org.apache.flink.runtime.checkpoint.CheckpointStatsTracker

public class CheckpointStatsTracker
extends Object

Tracker for checkpoint statistics.

This is tightly integrated with the CheckpointCoordinator in order to ease the gathering of fine-grained statistics.

The tracked stats include summary counts, a detailed history of recent and in progress checkpoints as well as summaries about the size, duration and more of recent checkpoints.

Data is gathered via callbacks in the CheckpointCoordinator and related classes like PendingCheckpoint and CompletedCheckpoint, which receive the raw stats data in the first place.

The statistics are accessed via createSnapshot() and exposed via both the web frontend and the Metric system.

Constructor Summary

Constructors

Constructor and Description
CheckpointStatsTracker(int numRememberedCheckpoints, MetricGroup metricGroup) Creates a new checkpoint stats tracker.

Method Summary

Modifier and Type	Method and Description
CheckpointStatsSnapshot	createSnapshot() Creates a new snapshot of the available stats.
PendingCheckpointStats	getPendingCheckpointStats(long checkpointId)
void	reportFailedCheckpointsWithoutInProgress() Callback when a checkpoint failure without in progress checkpoint.
void	reportIncompleteStats(long checkpointId, ExecutionVertex vertex, CheckpointMetrics metrics)

Methods inherited from class java.lang.Object

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

Constructor Detail

CheckpointStatsTracker

public CheckpointStatsTracker(int numRememberedCheckpoints,
                              MetricGroup metricGroup)

Creates a new checkpoint stats tracker.

Parameters:

numRememberedCheckpoints - Maximum number of checkpoints to remember, including in progress ones.

metricGroup - Metric group for exposed metrics

Method Detail

createSnapshot

public CheckpointStatsSnapshot createSnapshot()

Creates a new snapshot of the available stats.

Returns:

The latest statistics snapshot.

reportFailedCheckpointsWithoutInProgress

public void reportFailedCheckpointsWithoutInProgress()

Callback when a checkpoint failure without in progress checkpoint. For example, it should be callback when triggering checkpoint failure before creating PendingCheckpoint.

getPendingCheckpointStats

public PendingCheckpointStats getPendingCheckpointStats(long checkpointId)

reportIncompleteStats

public void reportIncompleteStats(long checkpointId,
                                  ExecutionVertex vertex,
                                  CheckpointMetrics metrics)