Package | Description |
---|---|
org.apache.flink.contrib.streaming.state.snapshot | |
org.apache.flink.runtime.state |
Modifier and Type | Class and Description |
---|---|
class |
RocksDBSnapshotStrategyBase<K,R extends SnapshotResources>
Abstract base class for
SnapshotStrategy implementations for RocksDB state backend. |
class |
RocksIncrementalSnapshotStrategy<K>
Snapshot strategy for
RocksDBKeyedStateBackend
that is based on RocksDB's native checkpoints and creates incremental snapshots. |
class |
RocksNativeFullSnapshotStrategy<K>
Snapshot strategy for
RocksDBKeyedStateBackend based on RocksDB's native checkpoints and
creates full snapshots. the difference between savepoint is that sst files will be uploaded
rather than states. |
Modifier and Type | Class and Description |
---|---|
class |
SavepointSnapshotStrategy<K>
A
SnapshotStrategy that produces unified savepoints. |
Constructor and Description |
---|
SnapshotStrategyRunner(String description,
SnapshotStrategy<T,SR> snapshotStrategy,
CloseableRegistry cancelStreamRegistry,
SnapshotExecutionType executionType) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.