Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.checkpoint.savepoint |
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) |
Modifier and Type | Method and Description |
---|---|
Collection<TaskState> |
SavepointV0.getTaskStates() |
Collection<TaskState> |
Savepoint.getTaskStates()
Returns the snapshotted task states.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.