Package org.apache.flink.state.rocksdb.restore

Class RocksDBIncrementalRestoreOperation<K>

java.lang.Object

org.apache.flink.state.rocksdb.restore.RocksDBIncrementalRestoreOperation<K>

All Implemented Interfaces:

AutoCloseable, org.apache.flink.runtime.state.RestoreOperation<RocksDBRestoreResult>, RocksDBRestoreOperation

public class RocksDBIncrementalRestoreOperation<K>
extends Object
implements RocksDBRestoreOperation

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

Constructor Summary

Constructors

Constructor

Description

RocksDBIncrementalRestoreOperation(String operatorIdentifier, org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, int keyGroupPrefixBytes, int numberOfTransferringThreads, org.apache.flink.util.ResourceGuard dbResourceGuard, org.apache.flink.core.fs.CloseableRegistry cancelStreamRegistryForRestore, org.apache.flink.core.fs.CloseableRegistry cancelRegistryForBackend, ClassLoader userCodeClassLoader, Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, org.apache.flink.runtime.state.StateSerializerProvider<K> keySerializerProvider, File instanceBasePath, File instanceRocksDBPath, org.rocksdb.DBOptions dbOptions, Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDBNativeMetricOptions nativeMetricOptions, org.apache.flink.metrics.MetricGroup metricGroup, org.apache.flink.runtime.state.StateBackend.CustomInitializationMetrics customInitializationMetrics, Collection<org.apache.flink.runtime.state.IncrementalKeyedStateHandle> restoreStateHandles, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, long writeBatchSize, Long writeBufferManagerCapacity, double overlapFractionThreshold, boolean useIngestDbRestoreMode, boolean asyncCompactAfterRescale, boolean useDeleteFilesInRange, ExecutorService ioExecutor, org.apache.flink.runtime.taskmanager.AsyncExceptionHandler asyncExceptionHandler)

Method Summary

Modifier and Type	Method	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,
                                          org.apache.flink.runtime.state.KeyGroupRange keyGroupRange,
                                          int keyGroupPrefixBytes,
                                          int numberOfTransferringThreads,
                                          org.apache.flink.util.ResourceGuard dbResourceGuard,
                                          org.apache.flink.core.fs.CloseableRegistry cancelStreamRegistryForRestore,
                                          org.apache.flink.core.fs.CloseableRegistry cancelRegistryForBackend,
                                          ClassLoader userCodeClassLoader,
                                          Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation,
                                          org.apache.flink.runtime.state.StateSerializerProvider<K> keySerializerProvider,
                                          File instanceBasePath,
                                          File instanceRocksDBPath,
                                          org.rocksdb.DBOptions dbOptions,
                                          Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
                                          RocksDBNativeMetricOptions nativeMetricOptions,
                                          org.apache.flink.metrics.MetricGroup metricGroup,
                                          org.apache.flink.runtime.state.StateBackend.CustomInitializationMetrics customInitializationMetrics,
                                          @Nonnull
                                          Collection<org.apache.flink.runtime.state.IncrementalKeyedStateHandle> restoreStateHandles,
                                          @Nonnull
                                          RocksDbTtlCompactFiltersManager ttlCompactFiltersManager,
                                          @Nonnegative
                                          long writeBatchSize,
                                          Long writeBufferManagerCapacity,
                                          double overlapFractionThreshold,
                                          boolean useIngestDbRestoreMode,
                                          boolean asyncCompactAfterRescale,
                                          boolean useDeleteFilesInRange,
                                          ExecutorService ioExecutor,
                                          org.apache.flink.runtime.taskmanager.AsyncExceptionHandler asyncExceptionHandler)

Method Detail

restore

public RocksDBRestoreResult restore()
                             throws Exception

Root method that branches for different implementations of IncrementalKeyedStateHandle.

Specified by:

restore in interface org.apache.flink.runtime.state.RestoreOperation<K>

Specified by:

restore in interface RocksDBRestoreOperation

Throws:

Exception

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception