K
- type of the backend keys.public abstract class RocksDBSnapshotStrategyBase<K,R extends SnapshotResources> extends Object implements CheckpointListener, SnapshotStrategy<KeyedStateHandle,R>, AutoCloseable
SnapshotStrategy
implementations for RocksDB state backend.SnapshotStrategy.SnapshotResultSupplier<S extends StateObject>
Modifier and Type | Field and Description |
---|---|
protected org.rocksdb.RocksDB |
db
RocksDB instance from the backend.
|
protected int |
keyGroupPrefixBytes
Number of bytes in the key-group prefix.
|
protected KeyGroupRange |
keyGroupRange
The key-group range for the task.
|
protected TypeSerializer<K> |
keySerializer
The key serializer of the backend.
|
protected LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> |
kvStateInformation
Key/Value state meta info from the backend.
|
protected LocalRecoveryConfig |
localRecoveryConfig
The configuration for local recovery.
|
protected ResourceGuard |
rocksDBResourceGuard
Resource guard for the RocksDB instance.
|
Constructor and Description |
---|
RocksDBSnapshotStrategyBase(String description,
org.rocksdb.RocksDB db,
ResourceGuard rocksDBResourceGuard,
TypeSerializer<K> keySerializer,
LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation,
KeyGroupRange keyGroupRange,
int keyGroupPrefixBytes,
LocalRecoveryConfig localRecoveryConfig) |
Modifier and Type | Method and Description |
---|---|
abstract void |
close() |
String |
getDescription() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
notifyCheckpointAborted, notifyCheckpointComplete
asyncSnapshot, syncPrepareResources
@Nonnull protected org.rocksdb.RocksDB db
@Nonnull protected final ResourceGuard rocksDBResourceGuard
@Nonnull protected final TypeSerializer<K> keySerializer
@Nonnull protected final LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation
@Nonnull protected final KeyGroupRange keyGroupRange
@Nonnegative protected final int keyGroupPrefixBytes
@Nonnull protected final LocalRecoveryConfig localRecoveryConfig
public RocksDBSnapshotStrategyBase(@Nonnull String description, @Nonnull org.rocksdb.RocksDB db, @Nonnull ResourceGuard rocksDBResourceGuard, @Nonnull TypeSerializer<K> keySerializer, @Nonnull LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, @Nonnull KeyGroupRange keyGroupRange, @Nonnegative int keyGroupPrefixBytes, @Nonnull LocalRecoveryConfig localRecoveryConfig)
public abstract void close()
close
in interface AutoCloseable
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.