org.apache.flink.contrib.streaming.state.ttl

Class RocksDbTtlCompactFiltersManager

java.lang.Object

org.apache.flink.contrib.streaming.state.ttl.RocksDbTtlCompactFiltersManager

public class RocksDbTtlCompactFiltersManager
extends Object

RocksDB compaction filter utils for state with TTL.

Constructor Summary

Constructors

Constructor and Description
RocksDbTtlCompactFiltersManager(TtlTimeProvider ttlTimeProvider)

Method Summary

Modifier and Type	Method and 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)

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