Uses of Class
org.apache.flink.contrib.streaming.state.RocksIteratorWrapper

Packages that use RocksIteratorWrapper

Package	Description
org.apache.flink.contrib.streaming.state
org.apache.flink.contrib.streaming.state.iterator

Uses of RocksIteratorWrapper in org.apache.flink.contrib.streaming.state

Methods in org.apache.flink.contrib.streaming.state that return RocksIteratorWrapper

Modifier and Type	Method	Description
static RocksIteratorWrapper	RocksDBOperationUtils.getRocksIterator(org.rocksdb.RocksDB db, org.rocksdb.ColumnFamilyHandle columnFamilyHandle, org.rocksdb.ReadOptions readOptions)

Uses of RocksIteratorWrapper in org.apache.flink.contrib.streaming.state.iterator

Subclasses of RocksIteratorWrapper in org.apache.flink.contrib.streaming.state.iterator

Modifier and Type	Class	Description
class	RocksTransformingIteratorWrapper	Wrapper around RocksIterator that applies a given StateSnapshotTransformer to the elements during the iteration.

Fields in org.apache.flink.contrib.streaming.state.iterator declared as RocksIteratorWrapper

Modifier and Type	Field	Description
protected RocksIteratorWrapper	AbstractRocksStateKeysIterator.iterator

Constructors in org.apache.flink.contrib.streaming.state.iterator with parameters of type RocksIteratorWrapper

Constructor	Description
AbstractRocksStateKeysIterator(RocksIteratorWrapper iterator, String state, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, int keyGroupPrefixBytes, boolean ambiguousKeyPossible)
RocksStateKeysAndNamespaceIterator(RocksIteratorWrapper iterator, String state, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer, int keyGroupPrefixBytes, boolean ambiguousKeyPossible)
RocksStateKeysIterator(RocksIteratorWrapper iterator, String state, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, int keyGroupPrefixBytes, boolean ambiguousKeyPossible, byte[] namespaceBytes)

Constructor parameters in org.apache.flink.contrib.streaming.state.iterator with type arguments of type RocksIteratorWrapper

Constructor	Description
RocksStatesPerKeyGroupMergeIterator(org.apache.flink.core.fs.CloseableRegistry closeableRegistry, List<org.apache.flink.api.java.tuple.Tuple2<RocksIteratorWrapper,Integer>> kvStateIterators, List<SingleStateIterator> heapPriorityQueueIterators, int keyGroupPrefixByteCount)	Creates a new RocksStatesPerKeyGroupMergeIterator.