Package org.apache.flink.runtime.taskmanager

Interface CheckpointResponder

All Known Implementing Classes:

RpcCheckpointResponder

@Internal
public interface CheckpointResponder

Responder for checkpoint acknowledge and decline messages in the Task.

Method Summary

Modifier and Type	Method	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, CheckpointException checkpointException)	Declines the given checkpoint.
void	reportCheckpointMetrics(JobID jobID, ExecutionAttemptID executionAttemptID, long checkpointId, CheckpointMetrics checkpointMetrics)	Report metrics for the given checkpoint.
void	reportInitializationMetrics(JobID jobId, ExecutionAttemptID executionAttemptId, SubTaskInitializationMetrics initializationMetrics)

Method Detail

acknowledgeCheckpoint

void acknowledgeCheckpoint(JobID jobID,
                           ExecutionAttemptID executionAttemptID,
                           long checkpointId,
                           CheckpointMetrics checkpointMetrics,
                           TaskStateSnapshot subtaskState)

Acknowledges the given checkpoint.

Parameters:

jobID - Job ID of the running job

executionAttemptID - Execution attempt ID of the running task

checkpointId - Meta data for this checkpoint

checkpointMetrics - Metrics of this checkpoint

subtaskState - State handles for the checkpoint

reportCheckpointMetrics

void reportCheckpointMetrics(JobID jobID,
                             ExecutionAttemptID executionAttemptID,
                             long checkpointId,
                             CheckpointMetrics checkpointMetrics)

Report metrics for the given checkpoint. Can be used upon receiving abortion notification.

Parameters:

jobID - Job ID of the running job

executionAttemptID - Execution attempt ID of the running task

checkpointId - Meta data for this checkpoint

checkpointMetrics - Metrics of this checkpoint

declineCheckpoint

void declineCheckpoint(JobID jobID,
                       ExecutionAttemptID executionAttemptID,
                       long checkpointId,
                       CheckpointException checkpointException)

Declines the given checkpoint.

Parameters:

jobID - Job ID of the running job

executionAttemptID - Execution attempt ID of the running task

checkpointId - The ID of the declined checkpoint

checkpointException - The exception why the checkpoint was declined

reportInitializationMetrics

void reportInitializationMetrics(JobID jobId,
                                 ExecutionAttemptID executionAttemptId,
                                 SubTaskInitializationMetrics initializationMetrics)