Package org.apache.flink.state.forst

Class ForStDBTtlCompactFiltersManager

java.lang.Object

org.apache.flink.state.forst.ForStDBTtlCompactFiltersManager

public class ForStDBTtlCompactFiltersManager
extends Object

RocksDB compaction filter utils for state with TTL.

Constructor Summary

Constructors

Constructor	Description
ForStDBTtlCompactFiltersManager(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.forstdb.ColumnFamilyOptions options)
void	setAndRegisterCompactFilterIfStateTtlV2(RegisteredStateMetaInfoBase metaInfoBase, org.forstdb.ColumnFamilyOptions options)

Methods inherited from class java.lang.Object

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

Constructor Detail

ForStDBTtlCompactFiltersManager

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

Method Detail

setAndRegisterCompactFilterIfStateTtl

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

setAndRegisterCompactFilterIfStateTtlV2

public void setAndRegisterCompactFilterIfStateTtlV2(@Nonnull
                                                    RegisteredStateMetaInfoBase metaInfoBase,
                                                    @Nonnull
                                                    org.forstdb.ColumnFamilyOptions options)

configCompactFilter

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

disposeAndClearRegisteredCompactionFactories

public void disposeAndClearRegisteredCompactionFactories()