public class SimpleCheckpointStatsTracker extends Object implements CheckpointStatsTracker
Constructor and Description |
---|
SimpleCheckpointStatsTracker(int historySize,
List<ExecutionJobVertex> tasksToWaitFor,
MetricGroup metrics) |
Modifier and Type | Method and Description |
---|---|
scala.Option<JobCheckpointStats> |
getJobStats()
Returns a snapshot of the checkpoint statistics for a job.
|
scala.Option<OperatorCheckpointStats> |
getOperatorStats(JobVertexID operatorId)
Returns a snapshot of the checkpoint statistics for an operator.
|
void |
onCompletedCheckpoint(CompletedCheckpoint checkpoint)
Callback on a completed checkpoint.
|
public SimpleCheckpointStatsTracker(int historySize, List<ExecutionJobVertex> tasksToWaitFor, MetricGroup metrics)
public void onCompletedCheckpoint(CompletedCheckpoint checkpoint)
CheckpointStatsTracker
onCompletedCheckpoint
in interface CheckpointStatsTracker
checkpoint
- The completed checkpoint.public scala.Option<JobCheckpointStats> getJobStats()
CheckpointStatsTracker
getJobStats
in interface CheckpointStatsTracker
public scala.Option<OperatorCheckpointStats> getOperatorStats(JobVertexID operatorId)
CheckpointStatsTracker
getOperatorStats
in interface CheckpointStatsTracker
operatorId
- The operator ID to gather the stats for.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.