org.apache.paimon.lookup

Class RocksDBStateFactory

java.lang.Object

org.apache.paimon.lookup.RocksDBStateFactory

All Implemented Interfaces:

Closeable, AutoCloseable

public class RocksDBStateFactory
extends Object
implements Closeable

Factory to create state.

Field Summary

Fields

Modifier and Type	Field and Description
static String	MERGE_OPERATOR_NAME

Constructor Summary

Constructors

Constructor and Description
RocksDBStateFactory(String path, Options conf, java.time.Duration ttlSecs)

Method Summary

Modifier and Type	Method and Description
void	close()
org.rocksdb.RocksDB	db()
<K,V> RocksDBListState<K,V>	listState(String name, Serializer<K> keySerializer, Serializer<V> valueSerializer, long lruCacheSize)
org.rocksdb.Options	options()
String	path()
<K,V> RocksDBSetState<K,V>	setState(String name, Serializer<K> keySerializer, Serializer<V> valueSerializer, long lruCacheSize)
<K,V> RocksDBValueState<K,V>	valueState(String name, Serializer<K> keySerializer, Serializer<V> valueSerializer, long lruCacheSize)

Methods inherited from class java.lang.Object

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

Field Detail

MERGE_OPERATOR_NAME

public static final String MERGE_OPERATOR_NAME

See Also:

Constant Field Values

Constructor Detail

RocksDBStateFactory

public RocksDBStateFactory(String path,
                           Options conf,
                           @Nullable
                           java.time.Duration ttlSecs)
                    throws IOException

Throws:

IOException

Method Detail

db

public org.rocksdb.RocksDB db()

options

public org.rocksdb.Options options()

path

public String path()

valueState

public <K,V> RocksDBValueState<K,V> valueState(String name,
                                               Serializer<K> keySerializer,
                                               Serializer<V> valueSerializer,
                                               long lruCacheSize)
                                        throws IOException

Throws:

IOException

setState

public <K,V> RocksDBSetState<K,V> setState(String name,
                                           Serializer<K> keySerializer,
                                           Serializer<V> valueSerializer,
                                           long lruCacheSize)
                                    throws IOException

Throws:

IOException

listState

public <K,V> RocksDBListState<K,V> listState(String name,
                                             Serializer<K> keySerializer,
                                             Serializer<V> valueSerializer,
                                             long lruCacheSize)
                                      throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException