public class RocksDBHeapTimersFullRestoreOperation<K> extends Object implements RocksDBRestoreOperation
Constructor and Description |
---|
RocksDBHeapTimersFullRestoreOperation(KeyGroupRange keyGroupRange,
int numberOfKeyGroups,
ClassLoader userCodeClassLoader,
Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation,
LinkedHashMap<String,HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates,
HeapPriorityQueueSetFactory priorityQueueFactory,
StateSerializerProvider<K> keySerializerProvider,
File instanceRocksDBPath,
org.rocksdb.DBOptions dbOptions,
Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
RocksDBNativeMetricOptions nativeMetricOptions,
MetricGroup metricGroup,
Collection<KeyedStateHandle> restoreStateHandles,
RocksDbTtlCompactFiltersManager ttlCompactFiltersManager,
long writeBatchSize,
Long writeBufferManagerCapacity) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
RocksDBRestoreResult |
restore()
Restores all key-groups data that is referenced by the passed state handles.
|
public RocksDBHeapTimersFullRestoreOperation(KeyGroupRange keyGroupRange, int numberOfKeyGroups, ClassLoader userCodeClassLoader, Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, LinkedHashMap<String,HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates, HeapPriorityQueueSetFactory priorityQueueFactory, StateSerializerProvider<K> keySerializerProvider, File instanceRocksDBPath, org.rocksdb.DBOptions dbOptions, Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDBNativeMetricOptions nativeMetricOptions, MetricGroup metricGroup, @Nonnull Collection<KeyedStateHandle> restoreStateHandles, @Nonnull RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, @Nonnegative long writeBatchSize, Long writeBufferManagerCapacity)
public RocksDBRestoreResult restore() throws IOException, StateMigrationException, org.rocksdb.RocksDBException
restore
in interface RocksDBRestoreOperation
restore
in interface RestoreOperation<RocksDBRestoreResult>
IOException
StateMigrationException
org.rocksdb.RocksDBException
public void close() throws Exception
close
in interface AutoCloseable
Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.