Uses of Class
org.apache.flink.state.rocksdb.ttl.RocksDbTtlCompactFiltersManager

Packages that use RocksDbTtlCompactFiltersManager

Package	Description
org.apache.flink.state.rocksdb
org.apache.flink.state.rocksdb.restore

Uses of RocksDbTtlCompactFiltersManager in org.apache.flink.state.rocksdb

Methods in org.apache.flink.state.rocksdb with parameters of type RocksDbTtlCompactFiltersManager

Modifier and Type	Method	Description
static org.rocksdb.ColumnFamilyDescriptor	RocksDBOperationUtils.createColumnFamilyDescriptor(RegisteredStateMetaInfoBase metaInfoBase, Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, Long writeBufferManagerCapacity)	Creates a column descriptor for a state column family.
static RocksDBKeyedStateBackend.RocksDbKvStateInfo	RocksDBOperationUtils.createStateInfo(RegisteredStateMetaInfoBase metaInfoBase, org.rocksdb.RocksDB db, Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, Long writeBufferManagerCapacity, List<org.rocksdb.ExportImportFilesMetaData> importFilesMetaData, ICloseableRegistry cancelStreamRegistryForRestore)	Creates a state info from a new meta info to use with a k/v state.
static RocksDBKeyedStateBackend.RocksDbKvStateInfo	RocksDBOperationUtils.createStateInfo(RegisteredStateMetaInfoBase metaInfoBase, org.rocksdb.RocksDB db, Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, Long writeBufferManagerCapacity, ICloseableRegistry cancelStreamRegistryForRestore)	Create RocksDB-backed KV-state, including RocksDB ColumnFamily.

Constructors in org.apache.flink.state.rocksdb with parameters of type RocksDbTtlCompactFiltersManager

Constructor

Description

RocksDBKeyedStateBackend(ClassLoader userCodeClassLoader, File instanceBasePath, RocksDBResourceContainer optionsContainer, Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, TaskKvStateRegistry kvStateRegistry, TypeSerializer<K> keySerializer, ExecutionConfig executionConfig, TtlTimeProvider ttlTimeProvider, LatencyTrackingStateConfig latencyTrackingStateConfig, org.rocksdb.RocksDB db, LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, Map<String,HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates, int keyGroupPrefixBytes, CloseableRegistry cancelStreamRegistry, StreamCompressionDecorator keyGroupCompressionDecorator, ResourceGuard rocksDBResourceGuard, RocksDBSnapshotStrategyBase<K,?> checkpointSnapshotStrategy, RocksDBWriteBatchWrapper writeBatchWrapper, org.rocksdb.ColumnFamilyHandle defaultColumnFamilyHandle, RocksDBNativeMetricMonitor nativeMetricMonitor, SerializedCompositeKeyBuilder<K> sharedRocksKeyBuilder, PriorityQueueSetFactory priorityQueueFactory, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, InternalKeyContext<K> keyContext, long writeBatchSize, CompletableFuture<Void> asyncCompactFuture, RocksDBManualCompactionManager rocksDBManualCompactionManager)

Uses of RocksDbTtlCompactFiltersManager in org.apache.flink.state.rocksdb.restore

Constructors in org.apache.flink.state.rocksdb.restore with parameters of type RocksDbTtlCompactFiltersManager

Constructor	Description
RocksDBFullRestoreOperation(KeyGroupRange keyGroupRange, ClassLoader userCodeClassLoader, Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, StateSerializerProvider<K> keySerializerProvider, File instanceRocksDBPath, org.rocksdb.DBOptions dbOptions, Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDBNativeMetricOptions nativeMetricOptions, MetricGroup metricGroup, Collection<KeyedStateHandle> restoreStateHandles, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, long writeBatchSize, Long writeBufferManagerCapacity, ICloseableRegistry cancelStreamRegistryForRestore)
RocksDBHeapTimersFullRestoreOperation(KeyGroupRange keyGroupRange, int numberOfKeyGroups, ClassLoader userCodeClassLoader, Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, LinkedHashMap<String,HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates, HeapPriorityQueueSetFactory priorityQueueFactory, StateSerializerProvider<K> keySerializerProvider, File instanceRocksDBPath, org.rocksdb.DBOptions dbOptions, Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDBNativeMetricOptions nativeMetricOptions, MetricGroup metricGroup, Collection<KeyedStateHandle> restoreStateHandles, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, long writeBatchSize, Long writeBufferManagerCapacity, ICloseableRegistry cancelStreamRegistryForRestore)
RocksDBIncrementalRestoreOperation(String operatorIdentifier, KeyGroupRange keyGroupRange, int keyGroupPrefixBytes, int numberOfTransferringThreads, ResourceGuard dbResourceGuard, CloseableRegistry cancelStreamRegistryForRestore, CloseableRegistry cancelRegistryForBackend, ClassLoader userCodeClassLoader, Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, StateSerializerProvider<K> keySerializerProvider, File instanceBasePath, File instanceRocksDBPath, org.rocksdb.DBOptions dbOptions, Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDBNativeMetricOptions nativeMetricOptions, MetricGroup metricGroup, StateBackend.CustomInitializationMetrics customInitializationMetrics, Collection<IncrementalKeyedStateHandle> restoreStateHandles, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, long writeBatchSize, Long writeBufferManagerCapacity, double overlapFractionThreshold, boolean useIngestDbRestoreMode, boolean asyncCompactAfterRescale, boolean useDeleteFilesInRange, ExecutorService ioExecutor, AsyncExceptionHandler asyncExceptionHandler)
RocksDBNoneRestoreOperation(Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, File instanceRocksDBPath, org.rocksdb.DBOptions dbOptions, Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDBNativeMetricOptions nativeMetricOptions, MetricGroup metricGroup, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, Long writeBufferManagerCapacity)