public class RocksDBValueState<K,V> extends RocksDBState<K,V,RocksDBState.Reference>
RocksDBState.ByteArray, RocksDBState.Reference
cache, columnFamily, db, keyOutView, keySerializer, stateFactory, valueInputView, valueOutputView, valueSerializer, writeOptions
Constructor and Description |
---|
RocksDBValueState(RocksDBStateFactory stateFactory,
org.rocksdb.ColumnFamilyHandle columnFamily,
Serializer<K> keySerializer,
Serializer<V> valueSerializer,
long lruCacheSize) |
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) |
createBulkLoader, createBulkLoadSorter, ref, serializeKey, wrap
public RocksDBValueState(RocksDBStateFactory stateFactory, org.rocksdb.ColumnFamilyHandle columnFamily, Serializer<K> keySerializer, Serializer<V> valueSerializer, long lruCacheSize)
@Nullable public V get(K key) throws IOException
IOException
public void put(K key, V value) throws IOException
IOException
public void delete(K key) throws IOException
IOException
public V deserializeValue(byte[] valueBytes) throws IOException
IOException
public byte[] serializeValue(V value) throws IOException
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.