org.apache.paimon.lookup

Class RocksDBState<K,V,CacheV>

java.lang.Object

org.apache.paimon.lookup.RocksDBState<K,V,CacheV>

Direct Known Subclasses:

RocksDBListState, RocksDBSetState, RocksDBValueState

public abstract class RocksDBState<K,V,CacheV>
extends Object

Rocksdb state for key value.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	RocksDBState.ByteArray A class wraps byte[] to implement equals and hashCode.
protected static class	RocksDBState.Reference A class wraps byte[] to indicate contain or not contain.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.Cache<RocksDBState.ByteArray,CacheV>	cache
protected org.rocksdb.ColumnFamilyHandle	columnFamily
protected org.rocksdb.RocksDB	db
protected DataOutputSerializer	keyOutView
protected Serializer<K>	keySerializer
protected RocksDBStateFactory	stateFactory
protected DataInputDeserializer	valueInputView
protected DataOutputSerializer	valueOutputView
protected Serializer<V>	valueSerializer
protected org.rocksdb.WriteOptions	writeOptions

Constructor Summary

Constructors

Constructor and Description
RocksDBState(RocksDBStateFactory stateFactory, org.rocksdb.ColumnFamilyHandle columnFamily, Serializer<K> keySerializer, Serializer<V> valueSerializer, long lruCacheSize)

Method Summary

Modifier and Type	Method and Description
BulkLoader	createBulkLoader()
static BinaryExternalSortBuffer	createBulkLoadSorter(IOManager ioManager, CoreOptions options)
protected RocksDBState.Reference	ref(byte[] bytes)
byte[]	serializeKey(K key)
protected RocksDBState.ByteArray	wrap(byte[] bytes)

Methods inherited from class java.lang.Object

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

Field Detail

stateFactory

protected final RocksDBStateFactory stateFactory

db

protected final org.rocksdb.RocksDB db

writeOptions

protected final org.rocksdb.WriteOptions writeOptions

columnFamily

protected final org.rocksdb.ColumnFamilyHandle columnFamily

keySerializer

protected final Serializer<K> keySerializer

valueSerializer

protected final Serializer<V> valueSerializer

keyOutView

protected final DataOutputSerializer keyOutView

valueInputView

protected final DataInputDeserializer valueInputView

valueOutputView

protected final DataOutputSerializer valueOutputView

cache

protected final org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.Cache<RocksDBState.ByteArray,CacheV> cache

Constructor Detail

RocksDBState

public RocksDBState(RocksDBStateFactory stateFactory,
                    org.rocksdb.ColumnFamilyHandle columnFamily,
                    Serializer<K> keySerializer,
                    Serializer<V> valueSerializer,
                    long lruCacheSize)

Method Detail

serializeKey

public byte[] serializeKey(K key)
                    throws IOException

Throws:

IOException

wrap

protected RocksDBState.ByteArray wrap(byte[] bytes)

ref

protected RocksDBState.Reference ref(byte[] bytes)

createBulkLoader

public BulkLoader createBulkLoader()

createBulkLoadSorter

public static BinaryExternalSortBuffer createBulkLoadSorter(IOManager ioManager,
                                                            CoreOptions options)