public class CheckpointStatsTracker extends Object
This is tightly integrated with the
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.
|Constructor and Description|
Creates a new checkpoint stats tracker.
|Modifier and Type||Method and Description|
Creates a new snapshot of the available stats.
Returns the job's snapshotting settings which are derived from the CheckpointConfig.
public CheckpointStatsTracker(int numRememberedCheckpoints, List<ExecutionJobVertex> jobVertices, JobCheckpointingSettings jobCheckpointingSettings, MetricGroup metricGroup)
numRememberedCheckpoints- Maximum number of checkpoints to remember, including in progress ones.
jobVertices- Job vertices involved in the checkpoints.
jobCheckpointingSettings- Snapshotting settings created from the CheckpointConfig.
metricGroup- Metric group for exposed metrics
public JobCheckpointingSettings getSnapshottingSettings()
public CheckpointStatsSnapshot createSnapshot()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.