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

Class RocksDBIncrementalRestoreOperation<K>

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, RocksDBRestoreOperation, RestoreOperation<RocksDBRestoreResult>

public class RocksDBIncrementalRestoreOperation<K>
extends Object
implements RocksDBRestoreOperation

Encapsulates the process of restoring a RocksDB instance from an incremental snapshot.

Constructor Summary

Constructors

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, Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDBNativeMetricOptions nativeMetricOptions, MetricGroup metricGroup, StateBackend.CustomInitializationMetrics customInitializationMetrics, Collection<IncrementalKeyedStateHandle> restoreStateHandles, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, long writeBatchSize, Long writeBufferManagerCapacity, double overlapFractionThreshold, boolean useIngestDbRestoreMode, boolean asyncCompactAfterRescale, boolean useDeleteFilesInRange, ExecutorService ioExecutor)

Method Summary

Modifier and Type	Method and Description
void	close()
RocksDBRestoreResult	restore() Root method that branches for different implementations of IncrementalKeyedStateHandle.

Methods inherited from class java.lang.Object

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

Constructor Detail

RocksDBIncrementalRestoreOperation

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,
                                          Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
                                          RocksDBNativeMetricOptions nativeMetricOptions,
                                          MetricGroup metricGroup,
                                          StateBackend.CustomInitializationMetrics customInitializationMetrics,
                                          @Nonnull
                                          Collection<IncrementalKeyedStateHandle> restoreStateHandles,
                                          @Nonnull
                                          RocksDbTtlCompactFiltersManager ttlCompactFiltersManager,
                                          @Nonnegative
                                          long writeBatchSize,
                                          Long writeBufferManagerCapacity,
                                          double overlapFractionThreshold,
                                          boolean useIngestDbRestoreMode,
                                          boolean asyncCompactAfterRescale,
                                          boolean useDeleteFilesInRange,
                                          ExecutorService ioExecutor)

Method Detail

restore

public RocksDBRestoreResult restore()
                             throws Exception

Root method that branches for different implementations of IncrementalKeyedStateHandle.

Specified by:

restore in interface RocksDBRestoreOperation

Specified by:

restore in interface RestoreOperation<RocksDBRestoreResult>

Throws:

Exception

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception