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
JobManager
and TaskManager to coordinate the checkpoint snapshots of the
distributed dataflow. |
org.apache.flink.runtime.state | |
org.apache.flink.runtime.taskexecutor.rpc | |
org.apache.flink.runtime.taskmanager |
Modifier and Type | Method and Description |
---|---|
SubtaskState |
TaskState.getState(int subtaskIndex)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Collection<SubtaskState> |
TaskState.getStates()
Deprecated.
|
Map<Integer,SubtaskState> |
TaskState.getSubtaskStates()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
CheckpointCoordinatorGateway.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
SubtaskState subtaskState) |
PendingCheckpoint.TaskAcknowledgeResult |
PendingCheckpoint.acknowledgeTask(ExecutionAttemptID executionAttemptId,
SubtaskState subtaskState,
CheckpointMetrics metrics)
Acknowledges the task with the given execution attempt id and the given subtask state.
|
void |
TaskState.putState(int subtaskIndex,
SubtaskState subtaskState)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
Environment.acknowledgeCheckpoint(long checkpointId,
CheckpointMetrics checkpointMetrics,
SubtaskState 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,
SubtaskState checkpointState) |
Modifier and Type | Method and Description |
---|---|
SubtaskState |
AcknowledgeCheckpoint.getSubtaskState() |
Constructor and Description |
---|
AcknowledgeCheckpoint(JobID job,
ExecutionAttemptID taskExecutionId,
long checkpointId,
CheckpointMetrics checkpointMetrics,
SubtaskState subtaskState) |
Constructor and Description |
---|
TaskStateHandles(SubtaskState checkpointStateHandles) |
Modifier and Type | Method and Description |
---|---|
void |
RpcCheckpointResponder.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
SubtaskState subtaskState) |
Modifier and Type | Method and Description |
---|---|
void |
CheckpointResponder.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
SubtaskState subtaskState)
Acknowledges the given checkpoint.
|
void |
ActorGatewayCheckpointResponder.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
SubtaskState checkpointStateHandles) |
void |
RuntimeEnvironment.acknowledgeCheckpoint(long checkpointId,
CheckpointMetrics checkpointMetrics,
SubtaskState checkpointStateHandles) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.