public class RocksDBIncrementalRestoreOperation<K> extends AbstractRocksDBRestoreOperation<K>
cancelStreamRegistry, columnFamilyDescriptors, columnFamilyHandles, columnFamilyOptionsFactory, db, dbOptions, dbPath, defaultColumnFamilyHandle, instanceBasePath, instanceRocksDBPath, isKeySerializerCompatibilityChecked, keyGroupPrefixBytes, keyGroupRange, keySerializerProvider, kvStateInformation, metricGroup, nativeMetricMonitor, nativeMetricOptions, numberOfTransferringThreads, restoreStateHandles, ttlCompactFiltersManager, userCodeClassLoader
Constructor and Description |
---|
RocksDBIncrementalRestoreOperation(String operatorIdentifier,
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> restoreStateHandles,
RocksDbTtlCompactFiltersManager ttlCompactFiltersManager,
long writeBatchSize) |
Modifier and Type | Method and Description |
---|---|
RocksDBRestoreResult |
restore()
Root method that branches for different implementations of
KeyedStateHandle . |
close, getDb
public RocksDBIncrementalRestoreOperation(String operatorIdentifier, 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> restoreStateHandles, @Nonnull RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, @Nonnegative long writeBatchSize)
public RocksDBRestoreResult restore() throws Exception
KeyedStateHandle
.restore
in interface RocksDBRestoreOperation
restore
in interface RestoreOperation<RocksDBRestoreResult>
restore
in class AbstractRocksDBRestoreOperation<K>
Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.