org.apache.flink.runtime.taskexecutor.rpc

Class RpcCheckpointResponder

java.lang.Object

org.apache.flink.runtime.taskexecutor.rpc.RpcCheckpointResponder

All Implemented Interfaces:

CheckpointResponder

public class RpcCheckpointResponder
extends Object
implements CheckpointResponder

Constructor Summary

Constructors

Constructor and Description
RpcCheckpointResponder(CheckpointCoordinatorGateway checkpointCoordinatorGateway)

Method Summary

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, 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, SubTaskInitializationMetrics initializationMetrics)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RpcCheckpointResponder

public RpcCheckpointResponder(CheckpointCoordinatorGateway checkpointCoordinatorGateway)

Method Detail

acknowledgeCheckpoint

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

Description copied from interface: CheckpointResponder

Acknowledges the given checkpoint.

Specified by:

acknowledgeCheckpoint in interface CheckpointResponder

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

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

Description copied from interface: CheckpointResponder

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

Specified by:

reportCheckpointMetrics in interface CheckpointResponder

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

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

Description copied from interface: CheckpointResponder

Declines the given checkpoint.

Specified by:

declineCheckpoint in interface CheckpointResponder

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

public void reportInitializationMetrics(JobID jobId,
                                        SubTaskInitializationMetrics initializationMetrics)

Specified by:

reportInitializationMetrics in interface CheckpointResponder