Package 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, org.apache.flink.runtime.state.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

Description

RocksDBIncrementalRestoreOperation(String operatorIdentifier, org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, int keyGroupPrefixBytes, int numberOfTransferringThreads, org.apache.flink.core.fs.CloseableRegistry cancelStreamRegistry, 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.KeyedStateHandle> restoreStateHandles, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, long writeBatchSize, Long writeBufferManagerCapacity, double overlapFractionThreshold)

Method Summary

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

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.core.fs.CloseableRegistry cancelStreamRegistry,
                                          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.KeyedStateHandle> restoreStateHandles,
                                          @Nonnull
                                          RocksDbTtlCompactFiltersManager ttlCompactFiltersManager,
                                          @Nonnegative
                                          long writeBatchSize,
                                          Long writeBufferManagerCapacity,
                                          double overlapFractionThreshold)

Method Detail

restore

public RocksDBRestoreResult restore()
                             throws Exception

Root method that branches for different implementations of KeyedStateHandle.

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