org.rocksdb

Class FlinkCompactionFilter

java.lang.Object

org.rocksdb.AbstractNativeReference

org.rocksdb.AbstractImmutableNativeReference

org.rocksdb.RocksObject

org.rocksdb.AbstractCompactionFilter<Slice>

org.rocksdb.FlinkCompactionFilter

All Implemented Interfaces:

java.lang.AutoCloseable

public class FlinkCompactionFilter
extends AbstractCompactionFilter<Slice>

Just a Java wrapper around FlinkCompactionFilter implemented in C++. Note: this compaction filter is a special implementation, designed for usage only in Apache Flink project.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FlinkCompactionFilter.Config
static class	FlinkCompactionFilter.FlinkCompactionFilterFactory
static interface	FlinkCompactionFilter.ListElementFilter
static interface	FlinkCompactionFilter.ListElementFilterFactory
static class	FlinkCompactionFilter.StateType
static interface	FlinkCompactionFilter.TimeProvider Provides current timestamp to check expiration, it must be thread safe.

Nested classes/interfaces inherited from class org.rocksdb.AbstractCompactionFilter

AbstractCompactionFilter.Context

Field Summary

Fields inherited from class org.rocksdb.RocksObject

nativeHandle_

Constructor Summary

Constructors

Constructor and Description
FlinkCompactionFilter(org.rocksdb.FlinkCompactionFilter.ConfigHolder configHolder, FlinkCompactionFilter.TimeProvider timeProvider)
FlinkCompactionFilter(org.rocksdb.FlinkCompactionFilter.ConfigHolder configHolder, FlinkCompactionFilter.TimeProvider timeProvider, Logger logger)

Method Summary

Methods inherited from class org.rocksdb.AbstractCompactionFilter

disposeInternal

Methods inherited from class org.rocksdb.RocksObject

disposeInternal

Methods inherited from class org.rocksdb.AbstractImmutableNativeReference

close, disOwnNativeHandle, isOwningHandle

Methods inherited from class org.rocksdb.AbstractNativeReference

dispose, finalize

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkCompactionFilter

public FlinkCompactionFilter(org.rocksdb.FlinkCompactionFilter.ConfigHolder configHolder,
                             FlinkCompactionFilter.TimeProvider timeProvider)

FlinkCompactionFilter

public FlinkCompactionFilter(org.rocksdb.FlinkCompactionFilter.ConfigHolder configHolder,
                             FlinkCompactionFilter.TimeProvider timeProvider,
                             Logger logger)