public class DisabledCheckpointStatsTracker extends Object implements CheckpointStatsTracker
Constructor and Description |
---|
DisabledCheckpointStatsTracker() |
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 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.