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.
|
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.storeSavepoint(String targetDirectory,
T savepoint)
Stores the savepoint.
|
Modifier and Type | Method and Description |
---|---|
static Savepoint |
SavepointStore.loadSavepoint(String path,
ClassLoader userClassLoader)
Loads the savepoint at the specified path.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.