org.rocksdb

Class FlinkCompactionFilter.FlinkCompactionFilterFactory

java.lang.Object

org.rocksdb.AbstractNativeReference

org.rocksdb.AbstractImmutableNativeReference

org.rocksdb.RocksCallbackObject

org.rocksdb.AbstractCompactionFilterFactory<FlinkCompactionFilter>

org.rocksdb.FlinkCompactionFilter.FlinkCompactionFilterFactory

All Implemented Interfaces:

java.lang.AutoCloseable

Enclosing class:

FlinkCompactionFilter

public static class FlinkCompactionFilter.FlinkCompactionFilterFactory
extends AbstractCompactionFilterFactory<FlinkCompactionFilter>

Field Summary

Fields inherited from class org.rocksdb.RocksCallbackObject

nativeHandle_

Constructor Summary

Constructors

Constructor and Description
FlinkCompactionFilterFactory(FlinkCompactionFilter.TimeProvider timeProvider)
FlinkCompactionFilterFactory(FlinkCompactionFilter.TimeProvider timeProvider, Logger logger)

Method Summary

Modifier and Type	Method and Description
void	close() Frees the underlying C++ object
void	configure(FlinkCompactionFilter.Config config)
FlinkCompactionFilter	createCompactionFilter(AbstractCompactionFilter.Context context) Create a new compaction filter
java.lang.String	name() A name which identifies this compaction filter The name will be printed to the LOG file on start up for diagnosis

Methods inherited from class org.rocksdb.AbstractCompactionFilterFactory

disposeInternal, initializeNative

Methods inherited from class org.rocksdb.AbstractImmutableNativeReference

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

FlinkCompactionFilterFactory

public FlinkCompactionFilterFactory(FlinkCompactionFilter.TimeProvider timeProvider)

FlinkCompactionFilterFactory

public FlinkCompactionFilterFactory(FlinkCompactionFilter.TimeProvider timeProvider,
                                    Logger logger)

Method Detail

close

public void close()

Description copied from class: AbstractNativeReference

Frees the underlying C++ object

It is strong recommended that the developer calls this after they have finished using the object.

Note, that once an instance of AbstractNativeReference has been disposed, calling any of its functions will lead to undefined behavior.

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class AbstractImmutableNativeReference

createCompactionFilter

public FlinkCompactionFilter createCompactionFilter(AbstractCompactionFilter.Context context)

Description copied from class: AbstractCompactionFilterFactory

Create a new compaction filter

Specified by:

createCompactionFilter in class AbstractCompactionFilterFactory<FlinkCompactionFilter>

Parameters:

context - The context describing the need for a new compaction filter

Returns:

A new instance of AbstractCompactionFilter

name

public java.lang.String name()

Description copied from class: AbstractCompactionFilterFactory

A name which identifies this compaction filter The name will be printed to the LOG file on start up for diagnosis

Specified by:

name in class AbstractCompactionFilterFactory<FlinkCompactionFilter>

configure

public void configure(FlinkCompactionFilter.Config config)