public interface CheckpointResponder
Task
.Modifier and Type | Method and Description |
---|---|
void |
acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot subtaskState)
Acknowledges the given checkpoint.
|
void |
declineCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
Throwable cause)
Declines the given checkpoint.
|
void acknowledgeCheckpoint(JobID jobID, ExecutionAttemptID executionAttemptID, long checkpointId, CheckpointMetrics checkpointMetrics, TaskStateSnapshot subtaskState)
jobID
- Job ID of the running jobexecutionAttemptID
- Execution attempt ID of the running taskcheckpointId
- Meta data for this checkpointcheckpointMetrics
- Metrics of this checkpointsubtaskState
- State handles for the checkpointvoid declineCheckpoint(JobID jobID, ExecutionAttemptID executionAttemptID, long checkpointId, Throwable cause)
jobID
- Job ID of the running jobexecutionAttemptID
- Execution attempt ID of the running taskcheckpointId
- The ID of the declined checkpointcause
- The optional cause why the checkpoint was declinedCopyright © 2014–2019 The Apache Software Foundation. All rights reserved.