public interface CheckpointStatsTracker
You can disable statistics by setting ConfigConstants.JOB_MANAGER_WEB_CHECKPOINTS_DISABLE
.
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.
|
void onCompletedCheckpoint(CompletedCheckpoint checkpoint)
checkpoint
- The completed checkpoint.scala.Option<JobCheckpointStats> getJobStats()
scala.Option<OperatorCheckpointStats> getOperatorStats(JobVertexID operatorId)
operatorId
- The operator ID to gather the stats for.IllegalArgumentException
- If unknown operator ID.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.