public class RocksDBSetState extends RocksDBState<List<byte[]>>
RocksDBState.ByteArray, RocksDBState.Reference
cache, columnFamily, db, keyOutView, keySerializer, valueInputView, valueOutputView, valueSerializer, writeOptions
Constructor and Description |
---|
RocksDBSetState(org.rocksdb.RocksDB db,
org.rocksdb.ColumnFamilyHandle columnFamily,
org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> keySerializer,
org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> valueSerializer,
long lruCacheSize) |
Modifier and Type | Method and Description |
---|---|
void |
add(org.apache.flink.table.data.RowData key,
org.apache.flink.table.data.RowData value) |
List<org.apache.flink.table.data.RowData> |
get(org.apache.flink.table.data.RowData key) |
void |
retract(org.apache.flink.table.data.RowData key,
org.apache.flink.table.data.RowData value) |
ref, serializeKey, wrap
public RocksDBSetState(org.rocksdb.RocksDB db, org.rocksdb.ColumnFamilyHandle columnFamily, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> keySerializer, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> valueSerializer, long lruCacheSize)
public List<org.apache.flink.table.data.RowData> get(org.apache.flink.table.data.RowData key) throws IOException
IOException
public void retract(org.apache.flink.table.data.RowData key, org.apache.flink.table.data.RowData value) throws IOException
IOException
public void add(org.apache.flink.table.data.RowData key, org.apache.flink.table.data.RowData value) throws IOException
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.