Package | Description |
---|---|
org.apache.flink.runtime.checkpoint |
Modifier and Type | Method and Description |
---|---|
List<StateForTask> |
PendingCheckpoint.getCollectedStates() |
List<StateForTask> |
CompletedCheckpoint.getStates() |
Constructor and Description |
---|
CompletedCheckpoint(JobID job,
long checkpointID,
long timestamp,
long completionTimestamp,
ArrayList<StateForTask> states) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.