Package org.apache.flink.state.rocksdb.ttl

Class RocksDbTtlCompactFiltersManager

java.lang.Object

org.apache.flink.state.rocksdb.ttl.RocksDbTtlCompactFiltersManager

public class RocksDbTtlCompactFiltersManager
extends Object

RocksDB compaction filter utils for state with TTL.

Constructor Summary

Constructors

Constructor	Description
RocksDbTtlCompactFiltersManager(TtlTimeProvider ttlTimeProvider, long queryTimeAfterNumEntries, Duration periodicCompactionTime)

Method Summary

Modifier and Type	Method	Description
void	configCompactFilter(StateDescriptor<?,?> stateDesc, TypeSerializer<?> stateSerializer)
void	disposeAndClearRegisteredCompactionFactories()
void	setAndRegisterCompactFilterIfStateTtl(RegisteredStateMetaInfoBase metaInfoBase, org.rocksdb.ColumnFamilyOptions options)

Methods inherited from class java.lang.Object

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

Constructor Detail

RocksDbTtlCompactFiltersManager

public RocksDbTtlCompactFiltersManager(TtlTimeProvider ttlTimeProvider,
                                       long queryTimeAfterNumEntries,
                                       Duration periodicCompactionTime)

Method Detail

setAndRegisterCompactFilterIfStateTtl

public void setAndRegisterCompactFilterIfStateTtl(@Nonnull
                                                  RegisteredStateMetaInfoBase metaInfoBase,
                                                  @Nonnull
                                                  org.rocksdb.ColumnFamilyOptions options)

configCompactFilter

public void configCompactFilter(@Nonnull
                                StateDescriptor<?,?> stateDesc,
                                TypeSerializer<?> stateSerializer)

disposeAndClearRegisteredCompactionFactories

public void disposeAndClearRegisteredCompactionFactories()