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. |
Modifier and Type | Field and Description |
---|---|
protected RocksIteratorWrapper |
AbstractRocksStateKeysIterator.iterator |
Constructor and Description |
---|
AbstractRocksStateKeysIterator(RocksIteratorWrapper iterator,
String state,
TypeSerializer<K> keySerializer,
int keyGroupPrefixBytes,
boolean ambiguousKeyPossible) |
RocksStateKeysAndNamespaceIterator(RocksIteratorWrapper iterator,
String state,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
int keyGroupPrefixBytes,
boolean ambiguousKeyPossible) |
RocksStateKeysIterator(RocksIteratorWrapper iterator,
String state,
TypeSerializer<K> keySerializer,
int keyGroupPrefixBytes,
boolean ambiguousKeyPossible,
byte[] namespaceBytes) |
Constructor and Description |
---|
RocksStatesPerKeyGroupMergeIterator(CloseableRegistry closeableRegistry,
List<Tuple2<RocksIteratorWrapper,Integer>> kvStateIterators,
List<SingleStateIterator> heapPriorityQueueIterators,
int keyGroupPrefixByteCount)
Creates a new
RocksStatesPerKeyGroupMergeIterator . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.