K
- The data type that the serializer serializes.public abstract class AbstractRocksDBRestoreOperation<K> extends Object implements RocksDBRestoreOperation, AutoCloseable
Modifier | Constructor and Description |
---|---|
protected |
AbstractRocksDBRestoreOperation(KeyGroupRange keyGroupRange,
int keyGroupPrefixBytes,
int numberOfTransferringThreads,
CloseableRegistry cancelStreamRegistry,
ClassLoader userCodeClassLoader,
Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation,
StateSerializerProvider<K> keySerializerProvider,
File instanceBasePath,
File instanceRocksDBPath,
org.rocksdb.DBOptions dbOptions,
java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
RocksDBNativeMetricOptions nativeMetricOptions,
MetricGroup metricGroup,
Collection<KeyedStateHandle> stateHandles,
RocksDbTtlCompactFiltersManager ttlCompactFiltersManager,
Long writeBufferManagerCapacity) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Necessary clean up iff restore operation failed.
|
org.rocksdb.RocksDB |
getDb() |
abstract RocksDBRestoreResult |
restore()
Restores state that was previously snapshot-ed from the provided state handles.
|
protected final org.slf4j.Logger logger
protected final KeyGroupRange keyGroupRange
protected final int keyGroupPrefixBytes
protected final int numberOfTransferringThreads
protected final CloseableRegistry cancelStreamRegistry
protected final ClassLoader userCodeClassLoader
protected final java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory
protected final org.rocksdb.DBOptions dbOptions
protected final Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation
protected final File instanceBasePath
protected final File instanceRocksDBPath
protected final String dbPath
protected List<org.rocksdb.ColumnFamilyHandle> columnFamilyHandles
protected List<org.rocksdb.ColumnFamilyDescriptor> columnFamilyDescriptors
protected final StateSerializerProvider<K> keySerializerProvider
protected final RocksDBNativeMetricOptions nativeMetricOptions
protected final MetricGroup metricGroup
protected final Collection<KeyedStateHandle> restoreStateHandles
protected final RocksDbTtlCompactFiltersManager ttlCompactFiltersManager
protected org.rocksdb.RocksDB db
protected org.rocksdb.ColumnFamilyHandle defaultColumnFamilyHandle
protected RocksDBNativeMetricMonitor nativeMetricMonitor
protected boolean isKeySerializerCompatibilityChecked
protected final Long writeBufferManagerCapacity
protected AbstractRocksDBRestoreOperation(KeyGroupRange keyGroupRange, int keyGroupPrefixBytes, int numberOfTransferringThreads, CloseableRegistry cancelStreamRegistry, ClassLoader userCodeClassLoader, Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, StateSerializerProvider<K> keySerializerProvider, File instanceBasePath, File instanceRocksDBPath, org.rocksdb.DBOptions dbOptions, java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDBNativeMetricOptions nativeMetricOptions, MetricGroup metricGroup, @Nonnull Collection<KeyedStateHandle> stateHandles, @Nonnull RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, Long writeBufferManagerCapacity)
public org.rocksdb.RocksDB getDb()
public void close()
close
in interface AutoCloseable
public abstract RocksDBRestoreResult restore() throws Exception
RocksDBRestoreOperation
restore
in interface RocksDBRestoreOperation
restore
in interface RestoreOperation<RocksDBRestoreResult>
Exception
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.