Modifier and Type | Field and Description |
---|---|
static int |
VERSION
The savepoint version.
|
Constructor and Description |
---|
SavepointV0(long checkpointId,
Collection<TaskState> taskStates) |
Modifier and Type | Method and Description |
---|---|
void |
dispose()
Disposes the savepoint.
|
boolean |
equals(Object o) |
long |
getCheckpointId()
Returns the checkpoint ID of the savepoint.
|
Collection<TaskState> |
getOldTaskStates() |
Collection<TaskState> |
getTaskStates()
Returns the snapshotted task states.
|
int |
getVersion()
Returns the version number of the object.
|
int |
hashCode() |
String |
toString() |
public static final int VERSION
public SavepointV0(long checkpointId, Collection<TaskState> taskStates)
public int getVersion()
Versioned
getVersion
in interface Versioned
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() throws Exception
Savepoint
public Collection<TaskState> getOldTaskStates()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.