Package | Description |
---|---|
org.apache.flink.migration.runtime.checkpoint.savepoint | |
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.checkpoint.savepoint |
Modifier and Type | Method and Description |
---|---|
Collection<TaskState> |
SavepointV0.getTaskStates() |
Modifier and Type | Method and Description |
---|---|
TaskState |
CompletedCheckpoint.getTaskState(JobVertexID jobVertexID) |
Modifier and Type | Method and Description |
---|---|
Map<JobVertexID,TaskState> |
PendingCheckpoint.getTaskStates() |
Map<JobVertexID,TaskState> |
CompletedCheckpoint.getTaskStates() |
Constructor and Description |
---|
CompletedCheckpoint(JobID job,
long checkpointID,
long timestamp,
long completionTimestamp,
Map<JobVertexID,TaskState> taskStates) |
CompletedCheckpoint(JobID job,
long checkpointID,
long timestamp,
long completionTimestamp,
Map<JobVertexID,TaskState> taskStates,
CheckpointProperties props,
String externalPath) |
StateAssignmentOperation(org.slf4j.Logger logger,
Map<JobVertexID,ExecutionJobVertex> tasks,
Map<JobVertexID,TaskState> taskStates,
boolean allowNonRestoredState) |
Modifier and Type | Method and Description |
---|---|
Collection<TaskState> |
SavepointV1.getTaskStates() |
Collection<TaskState> |
Savepoint.getTaskStates()
Returns the snapshotted task states.
|
Constructor and Description |
---|
SavepointV1(long checkpointId,
Collection<TaskState> taskStates) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.