public interface CheckpointCoordinatorGateway extends RpcGateway
Modifier and Type | Method and 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,
SubTaskInitializationMetrics initializationMetrics) |
getAddress, getHostname
void acknowledgeCheckpoint(JobID jobID, ExecutionAttemptID executionAttemptID, long checkpointId, CheckpointMetrics checkpointMetrics, @Nullable SerializedValue<TaskStateSnapshot> subtaskState)
void declineCheckpoint(DeclineCheckpoint declineCheckpoint)
void reportCheckpointMetrics(JobID jobID, ExecutionAttemptID executionAttemptID, long checkpointId, CheckpointMetrics checkpointMetrics)
void reportInitializationMetrics(JobID jobId, SubTaskInitializationMetrics initializationMetrics)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.