Package org.apache.flink.state.forst.restore

Class ForStHeapTimersFullRestoreOperation<K>

java.lang.Object

org.apache.flink.state.forst.restore.ForStHeapTimersFullRestoreOperation<K>

All Implemented Interfaces:

AutoCloseable, org.apache.flink.runtime.state.RestoreOperation<ForStRestoreResult>, ForStRestoreOperation

public class ForStHeapTimersFullRestoreOperation<K>
extends Object
implements ForStRestoreOperation

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

Constructor Summary

Constructors

Constructor

Description

ForStHeapTimersFullRestoreOperation(org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, int numberOfKeyGroups, ClassLoader userCodeClassLoader, Map<String,ForStOperationUtils.ForStKvStateInfo> kvStateInformation, LinkedHashMap<String,org.apache.flink.runtime.state.heap.HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates, org.apache.flink.runtime.state.heap.HeapPriorityQueueSetFactory priorityQueueFactory, org.apache.flink.runtime.state.StateSerializerProvider<K> keySerializerProvider, org.apache.flink.core.fs.Path instanceRocksDBPath, org.forstdb.DBOptions dbOptions, Function<String,org.forstdb.ColumnFamilyOptions> columnFamilyOptionsFactory, ForStNativeMetricOptions nativeMetricOptions, org.apache.flink.metrics.MetricGroup metricGroup, ForStDBTtlCompactFiltersManager ttlCompactFiltersManager, long writeBatchSize, Long writeBufferManagerCapacity, Collection<org.apache.flink.runtime.state.KeyedStateHandle> restoreStateHandles, org.apache.flink.core.fs.ICloseableRegistry cancelStreamRegistryForRestore)

Method Summary

Modifier and Type	Method	Description
void	close()
ForStRestoreResult	restore()	Restores all key-groups data that is referenced by the passed state handles.

Methods inherited from class java.lang.Object

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

Constructor Detail

ForStHeapTimersFullRestoreOperation

public ForStHeapTimersFullRestoreOperation(org.apache.flink.runtime.state.KeyGroupRange keyGroupRange,
                                           int numberOfKeyGroups,
                                           ClassLoader userCodeClassLoader,
                                           Map<String,ForStOperationUtils.ForStKvStateInfo> kvStateInformation,
                                           LinkedHashMap<String,org.apache.flink.runtime.state.heap.HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates,
                                           org.apache.flink.runtime.state.heap.HeapPriorityQueueSetFactory priorityQueueFactory,
                                           org.apache.flink.runtime.state.StateSerializerProvider<K> keySerializerProvider,
                                           org.apache.flink.core.fs.Path instanceRocksDBPath,
                                           org.forstdb.DBOptions dbOptions,
                                           Function<String,org.forstdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
                                           ForStNativeMetricOptions nativeMetricOptions,
                                           org.apache.flink.metrics.MetricGroup metricGroup,
                                           @Nonnull
                                           ForStDBTtlCompactFiltersManager ttlCompactFiltersManager,
                                           @Nonnegative
                                           long writeBatchSize,
                                           Long writeBufferManagerCapacity,
                                           @Nonnull
                                           Collection<org.apache.flink.runtime.state.KeyedStateHandle> restoreStateHandles,
                                           org.apache.flink.core.fs.ICloseableRegistry cancelStreamRegistryForRestore)

Method Detail

restore

public ForStRestoreResult restore()
                           throws IOException,
                                  org.apache.flink.util.StateMigrationException,
                                  org.forstdb.RocksDBException

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

Specified by:

restore in interface ForStRestoreOperation

Specified by:

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

Throws:

IOException

org.apache.flink.util.StateMigrationException

org.forstdb.RocksDBException

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception