Uses of Class
org.apache.flink.state.forst.ForStDBTtlCompactFiltersManager

Packages that use ForStDBTtlCompactFiltersManager

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

Uses of ForStDBTtlCompactFiltersManager in org.apache.flink.state.forst

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

Modifier and Type	Method	Description
static org.forstdb.ColumnFamilyDescriptor	ForStOperationUtils.createColumnFamilyDescriptor(org.apache.flink.runtime.state.RegisteredStateMetaInfoBase metaInfoBase, Function<String,org.forstdb.ColumnFamilyOptions> columnFamilyOptionsFactory, ForStDBTtlCompactFiltersManager ttlCompactFiltersManager, Long writeBufferManagerCapacity)	Creates a column descriptor for a state column family.
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.

Constructors in org.apache.flink.state.forst with parameters of type ForStDBTtlCompactFiltersManager

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 ForStDBTtlCompactFiltersManager in org.apache.flink.state.forst.restore

Constructors in org.apache.flink.state.forst.restore with parameters of type ForStDBTtlCompactFiltersManager

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)
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 ForStDBTtlCompactFiltersManager in org.apache.flink.state.forst.sync

Constructors in org.apache.flink.state.forst.sync with parameters of type ForStDBTtlCompactFiltersManager

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.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)