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

类 RocksDBIncrementalRestoreOperation<K>

java.lang.Object

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

所有已实现的接口:

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.

构造器概要

构造器

构造器和说明

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, java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDBNativeMetricOptions nativeMetricOptions, org.apache.flink.metrics.MetricGroup metricGroup, Collection<org.apache.flink.runtime.state.KeyedStateHandle> restoreStateHandles, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, long writeBatchSize, Long writeBufferManagerCapacity, double overlapFractionThreshold)

方法概要

限定符和类型	方法和说明
void	close()
RocksDBRestoreResult	restore() Root method that branches for different implementations of KeyedStateHandle.

从类继承的方法 java.lang.Object

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

构造器详细资料

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,
                                          java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
                                          RocksDBNativeMetricOptions nativeMetricOptions,
                                          org.apache.flink.metrics.MetricGroup metricGroup,
                                          @Nonnull
                                          Collection<org.apache.flink.runtime.state.KeyedStateHandle> restoreStateHandles,
                                          @Nonnull
                                          RocksDbTtlCompactFiltersManager ttlCompactFiltersManager,
                                          @Nonnegative
                                          long writeBatchSize,
                                          Long writeBufferManagerCapacity,
                                          double overlapFractionThreshold)

方法详细资料

restore

public RocksDBRestoreResult restore()
                             throws Exception

Root method that branches for different implementations of KeyedStateHandle.

指定者:

restore 在接口中 RocksDBRestoreOperation

指定者:

restore 在接口中 org.apache.flink.runtime.state.RestoreOperation<RocksDBRestoreResult>

抛出:

Exception

close

public void close()
           throws Exception

指定者:

close 在接口中 AutoCloseable

抛出:

Exception