Interface | Description |
---|---|
Savepoint |
Savepoints are manually-triggered snapshots from which a program can be
resumed on submission.
|
SavepointSerializer<T extends Savepoint> |
Serializer for
Savepoint instances. |
SavepointStore |
Savepoint store used to persist
Savepoint instances. |
Class | Description |
---|---|
FsSavepointStore |
A file system based
SavepointStore . |
HeapSavepointStore |
Heap-backed savepoint store.
|
SavepointCoordinator |
The savepoint coordinator is a slightly modified variant of the regular
checkpoint coordinator.
|
SavepointCoordinatorDeActivator |
This actor listens to changes in the JobStatus and deactivates the
savepoint scheduler and discards all pending checkpoints.
|
SavepointSerializers |
Helper to access
SavepointSerializer for a specific savepoint version. |
SavepointStoreFactory |
Factory for
SavepointStore instances. |
SavepointV0 |
Savepoint version 0.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.