org.apache.paimon.lookup

Class RocksDBListState<K,V>

java.lang.Object

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

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

public class RocksDBListState<K,V>
extends RocksDBState<K,V,List<V>>

RocksDB state for key -> List of 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
RocksDBListState(RocksDBStateFactory stateFactory, org.rocksdb.ColumnFamilyHandle columnFamily, Serializer<K> keySerializer, Serializer<V> valueSerializer, long lruCacheSize)

Method Summary

Modifier and Type	Method and Description
void	add(K key, V value)
List<V>	get(K key)
byte[]	serializeList(List<byte[]> valueList)
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

RocksDBListState

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

Method Detail

add

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

Throws:

IOException

get

public List<V> get(K key)
            throws IOException

Throws:

IOException

serializeValue

public byte[] serializeValue(V value)
                      throws IOException

Throws:

IOException

serializeList

public byte[] serializeList(List<byte[]> valueList)
                     throws IOException

Throws:

IOException