org.apache.paimon.lookup

Class RocksDBValueState<K,V>

java.lang.Object

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

org.apache.paimon.lookup.RocksDBValueState<K,V>

public class RocksDBValueState<K,V>
extends RocksDBState<K,V,RocksDBState.Reference>

Rocksdb state for key -> a single value.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.paimon.lookup.RocksDBState

RocksDBState.ByteArray, RocksDBState.Reference

Field Summary

Fields inherited from class org.apache.paimon.lookup.RocksDBState

cache, columnFamily, db, keyOutView, keySerializer, stateFactory, valueInputView, valueOutputView, valueSerializer, writeOptions

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	delete(K key)
V	deserializeValue(byte[] valueBytes)
V	get(K key)
void	put(K key, V value)
byte[]	serializeValue(V value)

Methods inherited from class org.apache.paimon.lookup.RocksDBState

createBulkLoader, createBulkLoadSorter, ref, serializeKey, wrap

Methods inherited from class java.lang.Object

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

Constructor Detail

RocksDBValueState

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

Method Detail

get

@Nullable
public V get(K key)
                throws IOException

Throws:

IOException

put

public void put(K key,
                V value)
         throws IOException

Throws:

IOException

delete

public void delete(K key)
            throws IOException

Throws:

IOException

deserializeValue

public V deserializeValue(byte[] valueBytes)
                   throws IOException

Throws:

IOException

serializeValue

public byte[] serializeValue(V value)
                      throws IOException

Throws:

IOException