org.rocksdb

Class FlinkCompactionFilter.Config

java.lang.Object

org.rocksdb.FlinkCompactionFilter.Config

Enclosing class:

FlinkCompactionFilter

public static class FlinkCompactionFilter.Config
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static FlinkCompactionFilter.Config	createForFixedElementList(long ttl, long queryTimeAfterNumEntries, int fixedElementLength)
static FlinkCompactionFilter.Config	createForList(long ttl, long queryTimeAfterNumEntries, FlinkCompactionFilter.ListElementFilterFactory listElementFilterFactory)
static FlinkCompactionFilter.Config	createForMap(long ttl, long queryTimeAfterNumEntries)
static FlinkCompactionFilter.Config	createForValue(long ttl, long queryTimeAfterNumEntries)
static FlinkCompactionFilter.Config	createNotList(FlinkCompactionFilter.StateType stateType, int timestampOffset, long ttl, long queryTimeAfterNumEntries)

Methods inherited from class java.lang.Object

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

Method Detail

createNotList

public static FlinkCompactionFilter.Config createNotList(FlinkCompactionFilter.StateType stateType,
                                                         int timestampOffset,
                                                         long ttl,
                                                         long queryTimeAfterNumEntries)

createForValue

public static FlinkCompactionFilter.Config createForValue(long ttl,
                                                          long queryTimeAfterNumEntries)

createForMap

public static FlinkCompactionFilter.Config createForMap(long ttl,
                                                        long queryTimeAfterNumEntries)

createForFixedElementList

public static FlinkCompactionFilter.Config createForFixedElementList(long ttl,
                                                                     long queryTimeAfterNumEntries,
                                                                     int fixedElementLength)

createForList

public static FlinkCompactionFilter.Config createForList(long ttl,
                                                         long queryTimeAfterNumEntries,
                                                         FlinkCompactionFilter.ListElementFilterFactory listElementFilterFactory)