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

类 RocksDBFullRestoreOperation<K>

java.lang.Object

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

所有已实现的接口:

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

public class RocksDBFullRestoreOperation<K>
extends Object
implements RocksDBRestoreOperation

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

构造器概要

构造器

构造器和说明

RocksDBFullRestoreOperation(org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, ClassLoader userCodeClassLoader, Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, org.apache.flink.runtime.state.StateSerializerProvider<K> keySerializerProvider, 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)

方法概要

限定符和类型	方法和说明
void	close()
RocksDBRestoreResult	restore() Restores all key-groups data that is referenced by the passed state handles.

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

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

构造器详细资料

RocksDBFullRestoreOperation

public RocksDBFullRestoreOperation(org.apache.flink.runtime.state.KeyGroupRange keyGroupRange,
                                   ClassLoader userCodeClassLoader,
                                   Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation,
                                   org.apache.flink.runtime.state.StateSerializerProvider<K> keySerializerProvider,
                                   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)

方法详细资料

restore

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

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

指定者:

restore 在接口中 RocksDBRestoreOperation

指定者:

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

抛出:

IOException

org.apache.flink.util.StateMigrationException

org.rocksdb.RocksDBException

close

public void close()
           throws Exception

指定者:

close 在接口中 AutoCloseable

抛出:

Exception