public class RocksDBSetState<K,V> extends RocksDBState<K,V,List<byte[]>>
RocksDBState.ByteArray, RocksDBState.Reference
cache, columnFamily, db, keyOutView, keySerializer, stateFactory, valueInputView, valueOutputView, valueSerializer, writeOptions
Constructor and Description |
---|
RocksDBSetState(RocksDBStateFactory stateFactory,
org.rocksdb.ColumnFamilyHandle columnFamily,
Serializer<K> keySerializer,
Serializer<V> valueSerializer,
long lruCacheSize) |
Modifier and Type | Method and Description |
---|---|
void |
add(K key,
V value) |
List<V> |
get(K key) |
void |
retract(K key,
V value) |
createBulkLoader, createBulkLoadSorter, ref, serializeKey, wrap
public RocksDBSetState(RocksDBStateFactory stateFactory, org.rocksdb.ColumnFamilyHandle columnFamily, Serializer<K> keySerializer, Serializer<V> valueSerializer, long lruCacheSize)
public List<V> get(K key) throws IOException
IOException
public void retract(K key, V value) throws IOException
IOException
public void add(K key, V value) throws IOException
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.