org.apache.flink.contrib.streaming.state.restore

Class RocksDBNoneRestoreOperation<K>

java.lang.Object

org.apache.flink.contrib.streaming.state.restore.AbstractRocksDBRestoreOperation<K>

org.apache.flink.contrib.streaming.state.restore.RocksDBNoneRestoreOperation<K>

All Implemented Interfaces:

AutoCloseable, RocksDBRestoreOperation, RestoreOperation<RocksDBRestoreResult>

public class RocksDBNoneRestoreOperation<K>
extends AbstractRocksDBRestoreOperation<K>

Encapsulates the process of initiating a RocksDB instance without restore.

Field Summary

Fields inherited from class org.apache.flink.contrib.streaming.state.restore.AbstractRocksDBRestoreOperation

cancelStreamRegistry, columnFamilyDescriptors, columnFamilyHandles, columnFamilyOptionsFactory, db, dbOptions, dbPath, defaultColumnFamilyHandle, instanceBasePath, instanceRocksDBPath, isKeySerializerCompatibilityChecked, keyGroupPrefixBytes, keyGroupRange, keySerializerProvider, kvStateInformation, metricGroup, nativeMetricMonitor, nativeMetricOptions, numberOfTransferringThreads, restoreStateHandles, ttlCompactFiltersManager, userCodeClassLoader

Constructor Summary

Constructors

Constructor and Description

RocksDBNoneRestoreOperation(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)

Method Summary

Modifier and Type	Method and Description
RocksDBRestoreResult	restore() Restores state that was previously snapshot-ed from the provided state handles.

Methods inherited from class org.apache.flink.contrib.streaming.state.restore.AbstractRocksDBRestoreOperation

close, getDb

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RocksDBNoneRestoreOperation

public RocksDBNoneRestoreOperation(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)

Method Detail

restore

public RocksDBRestoreResult restore()
                             throws Exception

Description copied from interface: RocksDBRestoreOperation

Restores state that was previously snapshot-ed from the provided state handles.

Specified by:

restore in interface RocksDBRestoreOperation

Specified by:

restore in interface RestoreOperation<RocksDBRestoreResult>

Specified by:

restore in class AbstractRocksDBRestoreOperation<K>

Throws:

Exception