Package | Description |
---|---|
org.apache.flink.contrib.streaming.state | |
org.apache.flink.contrib.streaming.state.iterator |
Modifier and Type | Method and Description |
---|---|
static RocksIteratorWrapper |
RocksDBOperationUtils.getRocksIterator(org.rocksdb.RocksDB db,
org.rocksdb.ColumnFamilyHandle columnFamilyHandle,
org.rocksdb.ReadOptions readOptions) |
Modifier and Type | Class and Description |
---|---|
class |
RocksTransformingIteratorWrapper
Wrapper around
RocksIterator that applies a given StateSnapshotTransformer to the elements
during the iteration. |
Constructor and Description |
---|
RocksStateKeysIterator(RocksIteratorWrapper iterator,
String state,
TypeSerializer<K> keySerializer,
int keyGroupPrefixBytes,
boolean ambiguousKeyPossible,
byte[] namespaceBytes) |
Constructor and Description |
---|
RocksStatesPerKeyGroupMergeIterator(List<Tuple2<RocksIteratorWrapper,Integer>> kvStateIterators,
int keyGroupPrefixByteCount) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.