public class RocksDBValueState extends RocksDBState<RocksDBState.Reference>
RocksDBState.ByteArray, RocksDBState.Reference
cache, columnFamily, db, keyOutView, keySerializer, valueInputView, valueOutputView, valueSerializer, writeOptions
Constructor and Description |
---|
RocksDBValueState(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 |
delete(org.apache.flink.table.data.RowData key) |
org.apache.flink.table.data.RowData |
get(org.apache.flink.table.data.RowData key) |
void |
put(org.apache.flink.table.data.RowData key,
org.apache.flink.table.data.RowData value) |
ref, serializeKey, wrap
public RocksDBValueState(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)
@Nullable public org.apache.flink.table.data.RowData get(org.apache.flink.table.data.RowData key) throws IOException
IOException
public void put(org.apache.flink.table.data.RowData key, org.apache.flink.table.data.RowData value) throws IOException
IOException
public void delete(org.apache.flink.table.data.RowData key) throws IOException
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.