Package org.apache.flink.runtime.checkpoint

Interface CheckpointCoordinatorGateway

All Superinterfaces:

RpcGateway

All Known Subinterfaces:

JobMasterGateway

All Known Implementing Classes:

JobMaster

public interface CheckpointCoordinatorGateway
extends RpcGateway

RPC Gateway interface for messages to the CheckpointCoordinator.

Method Summary

Modifier and Type	Method	Description
void	acknowledgeCheckpoint(JobID jobID, ExecutionAttemptID executionAttemptID, long checkpointId, CheckpointMetrics checkpointMetrics, SerializedValue<TaskStateSnapshot> subtaskState)
void	declineCheckpoint(DeclineCheckpoint declineCheckpoint)
void	reportCheckpointMetrics(JobID jobID, ExecutionAttemptID executionAttemptID, long checkpointId, CheckpointMetrics checkpointMetrics)
void	reportInitializationMetrics(JobID jobId, ExecutionAttemptID executionAttemptId, SubTaskInitializationMetrics initializationMetrics)

Methods inherited from interface org.apache.flink.runtime.rpc.RpcGateway

getAddress, getHostname

Method Detail

acknowledgeCheckpoint

void acknowledgeCheckpoint(JobID jobID,
                           ExecutionAttemptID executionAttemptID,
                           long checkpointId,
                           CheckpointMetrics checkpointMetrics,
                           @Nullable
                           SerializedValue<TaskStateSnapshot> subtaskState)

declineCheckpoint

void declineCheckpoint(DeclineCheckpoint declineCheckpoint)

reportCheckpointMetrics

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

reportInitializationMetrics

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