Package | Description |
---|---|
org.apache.flink.migration.runtime.checkpoint.savepoint | |
org.apache.flink.runtime.checkpoint.savepoint |
Modifier and Type | Class and Description |
---|---|
class |
SavepointV0
Savepoint version 0.
|
Modifier and Type | Interface and Description |
---|---|
interface |
SavepointSerializer<T extends Savepoint>
Serializer for
Savepoint instances. |
Modifier and Type | Class and Description |
---|---|
class |
SavepointV1
Savepoint version 0.
|
class |
SavepointV2
The persistent checkpoint metadata, format version 2.
|
Modifier and Type | Method and Description |
---|---|
static <T extends Savepoint> |
SavepointSerializers.getSerializer(T savepoint)
Returns the
SavepointSerializer for the given savepoint. |
static <T extends Savepoint> |
SavepointStore.storeExternalizedCheckpointToHandle(String directory,
T savepoint)
Stores the externalized checkpoint metadata file to a state handle.
|
static <T extends Savepoint> |
SavepointStore.storeSavepoint(String directory,
T savepoint)
Stores the savepoint metadata file.
|
static <T extends Savepoint> |
SavepointStore.storeSavepointToHandle(String directory,
T savepoint)
Stores the savepoint metadata file to a state handle.
|
Modifier and Type | Method and Description |
---|---|
static Savepoint |
SavepointV2.convertToOperatorStateSavepointV2(Map<JobVertexID,ExecutionJobVertex> tasks,
Savepoint savepoint)
Deprecated.
Only kept for backwards-compatibility with versions < 1.3. Will be removed in the future.
|
static Savepoint |
SavepointStore.loadSavepoint(String savepointFileOrDirectory,
ClassLoader classLoader)
Loads the savepoint at the specified path.
|
Modifier and Type | Method and Description |
---|---|
static Tuple2<Savepoint,StreamStateHandle> |
SavepointStore.loadSavepointWithHandle(String savepointFileOrDirectory,
ClassLoader classLoader)
Loads the savepoint at the specified path.
|
Modifier and Type | Method and Description |
---|---|
static Savepoint |
SavepointV2.convertToOperatorStateSavepointV2(Map<JobVertexID,ExecutionJobVertex> tasks,
Savepoint savepoint)
Deprecated.
Only kept for backwards-compatibility with versions < 1.3. Will be removed in the future.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.