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 and Description
void	acknowledgeCheckpoint(JobID jobID, ExecutionAttemptID executionAttemptID, long checkpointId, CheckpointMetrics checkpointMetrics, TaskStateSnapshot subtaskState)
void	declineCheckpoint(DeclineCheckpoint declineCheckpoint)

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,
                           TaskStateSnapshot subtaskState)

declineCheckpoint

void declineCheckpoint(DeclineCheckpoint declineCheckpoint)