org.apache.flink.runtime.checkpoint

Interface CheckpointCoordinatorGateway

All Superinterfaces:

RpcGateway

All Known Subinterfaces:

JobMasterGateway

All Known Implementing Classes:

JobMaster

public interface CheckpointCoordinatorGateway
extends RpcGateway

Method Summary

Modifier and Type	Method and Description
void	acknowledgeCheckpoint(JobID jobID, ExecutionAttemptID executionAttemptID, long checkpointId, CheckpointMetrics checkpointMetrics, TaskStateSnapshot subtaskState)
void	declineCheckpoint(JobID jobID, ExecutionAttemptID executionAttemptID, long checkpointId, Throwable cause)

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(JobID jobID,
                       ExecutionAttemptID executionAttemptID,
                       long checkpointId,
                       Throwable cause)