Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.execution | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.messages.checkpoint |
This package contains the messages that are sent between
JobMaster and TaskExecutor to coordinate the checkpoint snapshots of the
distributed dataflow. |
org.apache.flink.runtime.scheduler | |
org.apache.flink.runtime.scheduler.adaptive | |
org.apache.flink.runtime.state | |
org.apache.flink.runtime.taskexecutor.rpc | |
org.apache.flink.runtime.taskmanager | |
org.apache.flink.state.api.runtime |
Modifier and Type | Method and Description |
---|---|
CheckpointMetrics |
CheckpointMetricsBuilder.build() |
CheckpointMetrics |
CheckpointMetricsBuilder.buildIncomplete() |
Modifier and Type | Method and Description |
---|---|
void |
CheckpointCoordinatorGateway.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
SerializedValue<TaskStateSnapshot> subtaskState) |
PendingCheckpoint.TaskAcknowledgeResult |
PendingCheckpoint.acknowledgeTask(ExecutionAttemptID executionAttemptId,
TaskStateSnapshot operatorSubtaskStates,
CheckpointMetrics metrics)
Acknowledges the task with the given execution attempt id and the given subtask state.
|
void |
CheckpointCoordinatorGateway.reportCheckpointMetrics(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics) |
void |
CheckpointStatsTracker.reportIncompleteStats(long checkpointId,
ExecutionVertex vertex,
CheckpointMetrics metrics) |
void |
CheckpointCoordinator.reportStats(long id,
ExecutionAttemptID attemptId,
CheckpointMetrics metrics) |
Modifier and Type | Method and Description |
---|---|
void |
Environment.acknowledgeCheckpoint(long checkpointId,
CheckpointMetrics checkpointMetrics)
Confirms that the invokable has successfully completed all steps it needed to to for the
checkpoint with the give checkpoint-ID.
|
void |
Environment.acknowledgeCheckpoint(long checkpointId,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot subtaskState)
Confirms that the invokable has successfully completed all required steps for the checkpoint
with the give checkpoint-ID.
|
Modifier and Type | Method and Description |
---|---|
void |
JobMaster.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
SerializedValue<TaskStateSnapshot> checkpointState) |
void |
JobMaster.reportCheckpointMetrics(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics) |
Modifier and Type | Method and Description |
---|---|
CheckpointMetrics |
AcknowledgeCheckpoint.getCheckpointMetrics() |
Constructor and Description |
---|
AcknowledgeCheckpoint(JobID job,
ExecutionAttemptID taskExecutionId,
long checkpointId,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot subtaskState) |
Modifier and Type | Method and Description |
---|---|
void |
SchedulerNG.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot checkpointState) |
void |
ExecutionGraphHandler.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot checkpointState) |
void |
SchedulerBase.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot checkpointState) |
void |
ExecutionGraphHandler.reportCheckpointMetrics(ExecutionAttemptID attemptId,
long id,
CheckpointMetrics metrics) |
void |
SchedulerNG.reportCheckpointMetrics(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics) |
void |
SchedulerBase.reportCheckpointMetrics(JobID jobID,
ExecutionAttemptID attemptId,
long id,
CheckpointMetrics metrics) |
Modifier and Type | Method and Description |
---|---|
void |
AdaptiveScheduler.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot checkpointState) |
void |
AdaptiveScheduler.reportCheckpointMetrics(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics) |
Modifier and Type | Method and Description |
---|---|
void |
TaskStateManager.reportIncompleteTaskStateSnapshots(CheckpointMetaData checkpointMetaData,
CheckpointMetrics checkpointMetrics)
Report the stats for state snapshots for an aborted checkpoint.
|
void |
TaskStateManagerImpl.reportIncompleteTaskStateSnapshots(CheckpointMetaData checkpointMetaData,
CheckpointMetrics checkpointMetrics) |
void |
TaskStateManager.reportTaskStateSnapshots(CheckpointMetaData checkpointMetaData,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot acknowledgedState,
TaskStateSnapshot localState)
Report the state snapshots for the operator instances running in the owning task.
|
void |
TaskStateManagerImpl.reportTaskStateSnapshots(CheckpointMetaData checkpointMetaData,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot acknowledgedState,
TaskStateSnapshot localState) |
Modifier and Type | Method and Description |
---|---|
void |
RpcCheckpointResponder.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot subtaskState) |
void |
RpcCheckpointResponder.reportCheckpointMetrics(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics) |
Modifier and Type | Method and Description |
---|---|
void |
CheckpointResponder.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot subtaskState)
Acknowledges the given checkpoint.
|
void |
RuntimeEnvironment.acknowledgeCheckpoint(long checkpointId,
CheckpointMetrics checkpointMetrics) |
void |
RuntimeEnvironment.acknowledgeCheckpoint(long checkpointId,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot checkpointStateHandles) |
void |
CheckpointResponder.reportCheckpointMetrics(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics)
Report metrics for the given checkpoint.
|
Modifier and Type | Method and Description |
---|---|
void |
SavepointEnvironment.acknowledgeCheckpoint(long checkpointId,
CheckpointMetrics checkpointMetrics) |
void |
SavepointEnvironment.acknowledgeCheckpoint(long checkpointId,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot subtaskState) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.