public interface CheckpointResponder
Task
.Modifier and Type | Method and Description |
---|---|
void |
acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
CheckpointMetaData checkpointMetaData,
SubtaskState 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, CheckpointMetaData checkpointMetaData, SubtaskState subtaskState)
jobID
- Job ID of the running jobexecutionAttemptID
- Execution attempt ID of the running tasksubtaskState
- State handles for the checkpointcheckpointMetaData
- Meta data for this 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–2017 The Apache Software Foundation. All rights reserved.