Uses of Class
org.apache.flink.state.forst.ForStOperationUtils.ForStKvStateInfo

Packages that use ForStOperationUtils.ForStKvStateInfo

Package	Description
org.apache.flink.state.forst
org.apache.flink.state.forst.restore
org.apache.flink.state.forst.snapshot
org.apache.flink.state.forst.sync

Uses of ForStOperationUtils.ForStKvStateInfo in org.apache.flink.state.forst

Methods in org.apache.flink.state.forst that return ForStOperationUtils.ForStKvStateInfo

Modifier and Type	Method	Description
static ForStOperationUtils.ForStKvStateInfo	ForStOperationUtils.createStateInfo(org.apache.flink.runtime.state.RegisteredStateMetaInfoBase metaInfoBase, org.forstdb.RocksDB db, Function<String,org.forstdb.ColumnFamilyOptions> columnFamilyOptionsFactory, ForStDBTtlCompactFiltersManager ttlCompactFiltersManager, Long writeBufferManagerCapacity, List<org.forstdb.ExportImportFilesMetaData> importFilesMetaData, org.apache.flink.core.fs.ICloseableRegistry cancelStreamRegistryForRestore)	Creates a state info from a new meta info to use with a k/v state.
static ForStOperationUtils.ForStKvStateInfo	ForStOperationUtils.createStateInfo(org.apache.flink.runtime.state.RegisteredStateMetaInfoBase metaInfoBase, org.forstdb.RocksDB db, Function<String,org.forstdb.ColumnFamilyOptions> columnFamilyOptionsFactory, ForStDBTtlCompactFiltersManager ttlCompactFiltersManager, Long writeBufferManagerCapacity, org.apache.flink.core.fs.ICloseableRegistry cancelStreamRegistryForRestore)	Create RocksDB-backed KV-state, including RocksDB ColumnFamily.

Methods in org.apache.flink.state.forst with parameters of type ForStOperationUtils.ForStKvStateInfo

Modifier and Type	Method	Description
static void	ForStOperationUtils.registerKvStateInformation(Map<String,ForStOperationUtils.ForStKvStateInfo> kvStateInformation, ForStNativeMetricMonitor nativeMetricMonitor, String columnFamilyName, ForStOperationUtils.ForStKvStateInfo registeredColumn)

Method parameters in org.apache.flink.state.forst with type arguments of type ForStOperationUtils.ForStKvStateInfo

Modifier and Type	Method	Description
static void	ForStOperationUtils.registerKvStateInformation(Map<String,ForStOperationUtils.ForStKvStateInfo> kvStateInformation, ForStNativeMetricMonitor nativeMetricMonitor, String columnFamilyName, ForStOperationUtils.ForStKvStateInfo registeredColumn)

Constructor parameters in org.apache.flink.state.forst with type arguments of type ForStOperationUtils.ForStKvStateInfo

Constructor

Description

ForStKeyedStateBackend(UUID backendUID, org.apache.flink.api.common.ExecutionConfig executionConfig, ForStResourceContainer optionsContainer, org.apache.flink.util.ResourceGuard resourceGuard, int keyGroupPrefixBytes, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, Supplier<org.apache.flink.runtime.state.SerializedCompositeKeyBuilder<K>> serializedKeyBuilder, Supplier<org.apache.flink.core.memory.DataOutputSerializer> valueSerializerView, Supplier<org.apache.flink.core.memory.DataInputDeserializer> valueDeserializerView, org.forstdb.RocksDB db, LinkedHashMap<String,ForStOperationUtils.ForStKvStateInfo> kvStateInformation, Map<String,org.apache.flink.runtime.state.heap.HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates, Function<String,org.forstdb.ColumnFamilyOptions> columnFamilyOptionsFactory, org.forstdb.ColumnFamilyHandle defaultColumnFamilyHandle, ForStSnapshotStrategyBase<K,?> snapshotStrategy, org.apache.flink.runtime.state.PriorityQueueSetFactory priorityQueueFactory, org.apache.flink.core.fs.CloseableRegistry cancelStreamRegistry, ForStNativeMetricMonitor nativeMetricMonitor, org.apache.flink.runtime.state.InternalKeyContext<K> keyContext, org.apache.flink.runtime.state.ttl.TtlTimeProvider ttlTimeProvider, ForStDBTtlCompactFiltersManager ttlCompactFiltersManager)

Uses of ForStOperationUtils.ForStKvStateInfo in org.apache.flink.state.forst.restore

Constructor parameters in org.apache.flink.state.forst.restore with type arguments of type ForStOperationUtils.ForStKvStateInfo

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)
ForStIncrementalRestoreOperation(String operatorIdentifier, org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, int keyGroupPrefixBytes, org.apache.flink.core.fs.CloseableRegistry cancelStreamRegistry, ClassLoader userCodeClassLoader, Map<String,ForStOperationUtils.ForStKvStateInfo> kvStateInformation, org.apache.flink.runtime.state.StateSerializerProvider<K> keySerializerProvider, ForStResourceContainer optionsContainer, org.apache.flink.core.fs.Path forstBasePath, 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, org.apache.flink.runtime.state.StateBackend.CustomInitializationMetrics customInitializationMetrics, Collection<org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle> restoreStateHandles, double overlapFractionThreshold, boolean useIngestDbRestoreMode, boolean useDeleteFilesInRange, org.apache.flink.core.execution.RecoveryClaimMode recoveryClaimMode, Function<org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshot,org.apache.flink.runtime.state.RegisteredStateMetaInfoBase> stateMetaInfoFactory)
ForStNoneRestoreOperation(Map<String,ForStOperationUtils.ForStKvStateInfo> kvStateInformation, 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)

Uses of ForStOperationUtils.ForStKvStateInfo in org.apache.flink.state.forst.snapshot

Fields in org.apache.flink.state.forst.snapshot with type parameters of type ForStOperationUtils.ForStKvStateInfo

Modifier and Type	Field	Description
protected LinkedHashMap<String,ForStOperationUtils.ForStKvStateInfo>	ForStSnapshotStrategyBase.kvStateInformation	Key/Value state meta info from the backend.

Constructor parameters in org.apache.flink.state.forst.snapshot with type arguments of type ForStOperationUtils.ForStKvStateInfo

Constructor	Description
ForStIncrementalSnapshotStrategy(org.forstdb.RocksDB db, org.apache.flink.util.ResourceGuard forstResourceGuard, ForStResourceContainer resourceContainer, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, LinkedHashMap<String,ForStOperationUtils.ForStKvStateInfo> kvStateInformation, org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, int keyGroupPrefixBytes, UUID backendUID, SortedMap<Long,Collection<org.apache.flink.runtime.state.IncrementalKeyedStateHandle.HandleAndLocalPath>> uploadedStateHandles, ForStStateDataTransfer stateTransfer, long lastCompletedCheckpointId)
ForStNativeFullSnapshotStrategy(String description, org.forstdb.RocksDB db, org.apache.flink.util.ResourceGuard resourceGuard, ForStResourceContainer resourceContainer, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, LinkedHashMap<String,ForStOperationUtils.ForStKvStateInfo> kvStateInformation, org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, int keyGroupPrefixBytes, UUID backendUID, ForStStateDataTransfer stateTransfer)
ForStNativeFullSnapshotStrategy(org.forstdb.RocksDB db, org.apache.flink.util.ResourceGuard resourceGuard, ForStResourceContainer resourceContainer, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, LinkedHashMap<String,ForStOperationUtils.ForStKvStateInfo> kvStateInformation, org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, int keyGroupPrefixBytes, UUID backendUID, ForStStateDataTransfer stateTransfer)
ForStSnapshotStrategyBase(String description, org.forstdb.RocksDB db, org.apache.flink.util.ResourceGuard resourceGuard, ForStResourceContainer resourceContainer, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, LinkedHashMap<String,ForStOperationUtils.ForStKvStateInfo> kvStateInformation, org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, int keyGroupPrefixBytes, UUID backendUID)

Uses of ForStOperationUtils.ForStKvStateInfo in org.apache.flink.state.forst.sync

Constructor parameters in org.apache.flink.state.forst.sync with type arguments of type ForStOperationUtils.ForStKvStateInfo

Constructor

Description

ForStSyncKeyedStateBackend(ClassLoader userCodeClassLoader, ForStResourceContainer optionsContainer, Function<String,org.forstdb.ColumnFamilyOptions> columnFamilyOptionsFactory, org.apache.flink.runtime.query.TaskKvStateRegistry kvStateRegistry, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, org.apache.flink.api.common.ExecutionConfig executionConfig, org.apache.flink.runtime.state.ttl.TtlTimeProvider ttlTimeProvider, org.apache.flink.runtime.state.metrics.LatencyTrackingStateConfig latencyTrackingStateConfig, org.apache.flink.runtime.state.metrics.SizeTrackingStateConfig sizeTrackingStateConfig, org.forstdb.RocksDB db, LinkedHashMap<String,ForStOperationUtils.ForStKvStateInfo> kvStateInformation, Map<String,org.apache.flink.runtime.state.heap.HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates, int keyGroupPrefixBytes, org.apache.flink.core.fs.CloseableRegistry cancelStreamRegistry, org.apache.flink.runtime.state.StreamCompressionDecorator keyGroupCompressionDecorator, org.apache.flink.util.ResourceGuard forstResourceGuard, ForStSnapshotStrategyBase<K,?> checkpointSnapshotStrategy, ForStDBWriteBatchWrapper writeBatchWrapper, org.forstdb.ColumnFamilyHandle defaultColumnFamilyHandle, ForStNativeMetricMonitor nativeMetricMonitor, org.apache.flink.runtime.state.SerializedCompositeKeyBuilder<K> sharedRocksKeyBuilder, org.apache.flink.runtime.state.PriorityQueueSetFactory priorityQueueFactory, ForStDBTtlCompactFiltersManager ttlCompactFiltersManager, org.apache.flink.runtime.state.InternalKeyContext<K> keyContext, long writeBatchSize, CompletableFuture<Void> asyncCompactFuture)