Package | Description |
---|---|
org.apache.flink.runtime.checkpoint.savepoint | |
org.apache.flink.runtime.testingUtils |
Modifier and Type | Interface and Description |
---|---|
interface |
SavepointSerializer<T extends Savepoint>
Serializer for
Savepoint instances. |
Modifier and Type | Class and Description |
---|---|
class |
SavepointV0
Savepoint version 0.
|
Modifier and Type | Method and Description |
---|---|
static <T extends Savepoint> |
SavepointSerializers.getSerializer(T savepoint)
Returns the
SavepointSerializer for the given savepoint. |
<T extends Savepoint> |
SavepointStore.storeSavepoint(T savepoint)
Stores the savepoint.
|
<T extends Savepoint> |
HeapSavepointStore.storeSavepoint(T savepoint) |
<T extends Savepoint> |
FsSavepointStore.storeSavepoint(T savepoint) |
Modifier and Type | Method and Description |
---|---|
Savepoint |
SavepointStore.loadSavepoint(String path)
Loads the savepoint at the specified path.
|
Savepoint |
HeapSavepointStore.loadSavepoint(String path) |
Savepoint |
FsSavepointStore.loadSavepoint(String path) |
Modifier and Type | Method and Description |
---|---|
Savepoint |
TestingJobManagerMessages.ResponseSavepoint.savepoint() |
Constructor and Description |
---|
ResponseSavepoint(Savepoint savepoint) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.