Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.execution | |
org.apache.flink.runtime.jobgraph.tasks | |
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.taskmanager | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Modifier and Type | Method and Description |
---|---|
CheckpointMetaData |
CheckpointMetaData.setAlignmentDurationNanos(long alignmentDurationNanos) |
CheckpointMetaData |
CheckpointMetaData.setAsyncDurationMillis(long asyncDurationMillis) |
CheckpointMetaData |
CheckpointMetaData.setBytesBufferedInAlignment(long bytesBufferedInAlignment) |
CheckpointMetaData |
CheckpointMetaData.setSyncDurationMillis(long syncDurationMillis) |
Modifier and Type | Method and Description |
---|---|
PendingCheckpoint.TaskAcknowledgeResult |
PendingCheckpoint.acknowledgeTask(ExecutionAttemptID executionAttemptId,
SubtaskState subtaskState,
CheckpointMetaData checkpointMetaData)
Acknowledges the task with the given execution attempt id and the given subtask state.
|
Modifier and Type | Method and Description |
---|---|
void |
Environment.acknowledgeCheckpoint(CheckpointMetaData checkpointMetaData)
Confirms that the invokable has successfully completed all steps it needed to
to for the checkpoint with the give checkpoint-ID.
|
void |
Environment.acknowledgeCheckpoint(CheckpointMetaData checkpointMetaData,
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 |
---|---|
boolean |
StatefulTask.triggerCheckpoint(CheckpointMetaData checkpointMetaData)
This method is called to trigger a checkpoint, asynchronously by the checkpoint
coordinator.
|
void |
StatefulTask.triggerCheckpointOnBarrier(CheckpointMetaData checkpointMetaData)
This method is called when a checkpoint is triggered as a result of receiving checkpoint
barriers on all input streams.
|
Modifier and Type | Method and Description |
---|---|
CheckpointMetaData |
AcknowledgeCheckpoint.getCheckpointMetaData() |
Constructor and Description |
---|
AcknowledgeCheckpoint(JobID job,
ExecutionAttemptID taskExecutionId,
CheckpointMetaData checkpointMetaData) |
AcknowledgeCheckpoint(JobID job,
ExecutionAttemptID taskExecutionId,
CheckpointMetaData checkpointMetaData,
SubtaskState subtaskState) |
Modifier and Type | Method and Description |
---|---|
void |
RuntimeEnvironment.acknowledgeCheckpoint(CheckpointMetaData checkpointMetaData) |
void |
RuntimeEnvironment.acknowledgeCheckpoint(CheckpointMetaData checkpointMetaData,
SubtaskState checkpointStateHandles) |
void |
CheckpointResponder.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
CheckpointMetaData checkpointMetaData,
SubtaskState subtaskState)
Acknowledges the given checkpoint.
|
void |
ActorGatewayCheckpointResponder.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
CheckpointMetaData checkpointMetaData,
SubtaskState checkpointStateHandles) |
Modifier and Type | Method and Description |
---|---|
boolean |
StreamTask.triggerCheckpoint(CheckpointMetaData checkpointMetaData) |
void |
StreamTask.triggerCheckpointOnBarrier(CheckpointMetaData checkpointMetaData) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.