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

Class RocksDBHeapTimersFullRestoreOperation<K>

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, RocksDBRestoreOperation, RestoreOperation<RocksDBRestoreResult>

public class RocksDBHeapTimersFullRestoreOperation<K>
extends Object
implements RocksDBRestoreOperation

Encapsulates the process of restoring a RocksDB instance from a full snapshot.

Constructor Summary

Constructors

Constructor

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, ICloseableRegistry cancelStreamRegistryForRestore)

Method Summary

Modifier and Type	Method	Description
void	close()
RocksDBRestoreResult	restore()	Restores all key-groups data that is referenced by the passed state handles.

Methods inherited from class java.lang.Object

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

Constructor Detail

RocksDBHeapTimersFullRestoreOperation

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,
                                             ICloseableRegistry cancelStreamRegistryForRestore)

Method Detail

restore

public RocksDBRestoreResult restore()
                             throws IOException,
                                    StateMigrationException,
                                    org.rocksdb.RocksDBException

Restores all key-groups data that is referenced by the passed state handles.

Specified by:

restore in interface RestoreOperation<K>

Specified by:

restore in interface RocksDBRestoreOperation

Throws:

IOException

StateMigrationException

org.rocksdb.RocksDBException

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception