public interface SavepointStore
Savepoint
instances.
The main implementation is the FsSavepointStore
. We also have the
HeapSavepointStore
for historical reasons (introduced in Flink 1.0).
Modifier and Type | Method and Description |
---|---|
void |
disposeSavepoint(String path,
ClassLoader classLoader)
Disposes the savepoint at the specified path.
|
Savepoint |
loadSavepoint(String path)
Loads the savepoint at the specified path.
|
void |
shutdown()
Shut downs the savepoint store.
|
<T extends Savepoint> |
storeSavepoint(T savepoint)
Stores the savepoint.
|
<T extends Savepoint> String storeSavepoint(T savepoint) throws Exception
T
- Savepoint typesavepoint
- Savepoint to be storedException
- Failures during store are forwardedSavepoint loadSavepoint(String path) throws Exception
path
- Path of savepoint to loadException
- Failures during load are forwaredvoid disposeSavepoint(String path, ClassLoader classLoader) throws Exception
The class loader is needed, because savepoints can currently point to
arbitrary snapshot StateHandle
instances, which need the user code class loader for deserialization.
path
- Path of savepoint to disposeclassLoader
- Class loader for disposalException
- Failures during diposal are forwardedCopyright © 2014–2017 The Apache Software Foundation. All rights reserved.