Modifier and Type | Field and Description |
---|---|
static int |
VERSION
The savepoint version.
|
Modifier and Type | Method and Description |
---|---|
void |
dispose(ClassLoader classLoader)
Disposes the savepoint.
|
boolean |
equals(Object o) |
long |
getCheckpointId()
Returns the checkpoint ID of the savepoint.
|
Collection<TaskState> |
getTaskStates()
Returns the snapshotted task states.
|
int |
getVersion()
Returns the savepoint version.
|
int |
hashCode() |
String |
toString() |
public static final int VERSION
public int getVersion()
Savepoint
This version is independent of the Flink version, e.g. multiple Flink versions can work the same savepoint version.
getVersion
in interface Savepoint
public long getCheckpointId()
Savepoint
Savepoints use the same mechanisms as regular checkpoints and are
identified by a unique ID. This ID is used to reset the CheckpointIDCounter
when restoring from a savepoint.
getCheckpointId
in interface Savepoint
public Collection<TaskState> getTaskStates()
Savepoint
These are used to restore the snapshot state.
getTaskStates
in interface Savepoint
public void dispose(ClassLoader classLoader) throws Exception
Savepoint
The class loader is needed, because savepoints can currently point to
arbitrary snapshot StateHandle
instances, which need the user code class loader for deserialization.
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.