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, List<ExecutionJobVertex> jobVertices, CheckpointCoordinatorConfiguration jobCheckpointingConfiguration, 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.
CheckpointCoordinatorConfiguration	getJobCheckpointingConfiguration() Returns the job's checkpointing configuration which is derived from the CheckpointConfig.

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,
                              List<ExecutionJobVertex> jobVertices,
                              CheckpointCoordinatorConfiguration jobCheckpointingConfiguration,
                              MetricGroup metricGroup)

Creates a new checkpoint stats tracker.

Parameters:

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

jobVertices - Job vertices involved in the checkpoints.

jobCheckpointingConfiguration - Checkpointing configuration.

metricGroup - Metric group for exposed metrics

Method Detail

getJobCheckpointingConfiguration

public CheckpointCoordinatorConfiguration getJobCheckpointingConfiguration()

Returns the job's checkpointing configuration which is derived from the CheckpointConfig.

Returns:

The job's checkpointing configuration.

createSnapshot

public CheckpointStatsSnapshot createSnapshot()

Creates a new snapshot of the available stats.

Returns:

The latest statistics snapshot.