public abstract class RocksDBState<CacheV> extends Object
Modifier and Type | Class and Description |
---|---|
protected static class |
RocksDBState.ByteArray
A class wraps byte[] to implement equals and hashCode.
|
protected static class |
RocksDBState.Reference
A class wraps byte[] to indicate contain or not contain.
|
Modifier and Type | Field and Description |
---|---|
protected org.apache.flink.shaded.guava30.com.google.common.cache.Cache<RocksDBState.ByteArray,CacheV> |
cache |
protected org.rocksdb.ColumnFamilyHandle |
columnFamily |
protected org.rocksdb.RocksDB |
db |
protected org.apache.flink.core.memory.DataOutputSerializer |
keyOutView |
protected org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> |
keySerializer |
protected org.apache.flink.core.memory.DataInputDeserializer |
valueInputView |
protected org.apache.flink.core.memory.DataOutputSerializer |
valueOutputView |
protected org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> |
valueSerializer |
protected org.rocksdb.WriteOptions |
writeOptions |
Constructor and Description |
---|
RocksDBState(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 |
---|---|
protected RocksDBState.Reference |
ref(byte[] bytes) |
protected byte[] |
serializeKey(org.apache.flink.table.data.RowData key) |
protected RocksDBState.ByteArray |
wrap(byte[] bytes) |
protected final org.rocksdb.RocksDB db
protected final org.rocksdb.WriteOptions writeOptions
protected final org.rocksdb.ColumnFamilyHandle columnFamily
protected final org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> keySerializer
protected final org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> valueSerializer
protected final org.apache.flink.core.memory.DataOutputSerializer keyOutView
protected final org.apache.flink.core.memory.DataInputDeserializer valueInputView
protected final org.apache.flink.core.memory.DataOutputSerializer valueOutputView
protected final org.apache.flink.shaded.guava30.com.google.common.cache.Cache<RocksDBState.ByteArray,CacheV> cache
public RocksDBState(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)
protected byte[] serializeKey(org.apache.flink.table.data.RowData key) throws IOException
IOException
protected RocksDBState.ByteArray wrap(byte[] bytes)
protected RocksDBState.Reference ref(byte[] bytes)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.