Class ForStIncrementalRestoreOperation<K>
- java.lang.Object
-
- org.apache.flink.state.forst.restore.ForStIncrementalRestoreOperation<K>
-
- All Implemented Interfaces:
AutoCloseable
,RestoreOperation<ForStRestoreResult>
,ForStRestoreOperation
public class ForStIncrementalRestoreOperation<K> extends Object implements ForStRestoreOperation
Encapsulates the process of restoring a ForSt instance from an incremental snapshot.
-
-
Constructor Summary
Constructors Constructor Description ForStIncrementalRestoreOperation(String operatorIdentifier, KeyGroupRange keyGroupRange, CloseableRegistry cancelStreamRegistry, ClassLoader userCodeClassLoader, Map<String,ForStKeyedStateBackend.ForStKvStateInfo> kvStateInformation, StateSerializerProvider<K> keySerializerProvider, ForStResourceContainer optionsContainer, Path forstBasePath, File instanceRocksDBPath, org.forstdb.DBOptions dbOptions, Function<String,org.forstdb.ColumnFamilyOptions> columnFamilyOptionsFactory, ForStNativeMetricOptions nativeMetricOptions, MetricGroup metricGroup, StateBackend.CustomInitializationMetrics customInitializationMetrics, Collection<IncrementalRemoteKeyedStateHandle> restoreStateHandles)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
ForStRestoreResult
restore()
Root method that branches for different implementations ofIncrementalKeyedStateHandle
.
-
-
-
Constructor Detail
-
ForStIncrementalRestoreOperation
public ForStIncrementalRestoreOperation(String operatorIdentifier, KeyGroupRange keyGroupRange, CloseableRegistry cancelStreamRegistry, ClassLoader userCodeClassLoader, Map<String,ForStKeyedStateBackend.ForStKvStateInfo> kvStateInformation, StateSerializerProvider<K> keySerializerProvider, ForStResourceContainer optionsContainer, Path forstBasePath, File instanceRocksDBPath, org.forstdb.DBOptions dbOptions, Function<String,org.forstdb.ColumnFamilyOptions> columnFamilyOptionsFactory, ForStNativeMetricOptions nativeMetricOptions, MetricGroup metricGroup, StateBackend.CustomInitializationMetrics customInitializationMetrics, @Nonnull Collection<IncrementalRemoteKeyedStateHandle> restoreStateHandles)
-
-
Method Detail
-
restore
public ForStRestoreResult restore() throws Exception
Root method that branches for different implementations ofIncrementalKeyedStateHandle
.- Specified by:
restore
in interfaceForStRestoreOperation
- Specified by:
restore
in interfaceRestoreOperation<K>
- Throws:
Exception
-
close
public void close() throws Exception
- Specified by:
close
in interfaceAutoCloseable
- Throws:
Exception
-
-