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

Class RocksMultiStateKeysIterator<K>

java.lang.Object

org.apache.flink.contrib.streaming.state.iterator.RocksMultiStateKeysIterator<K>

Type Parameters:

K - the type of the iterated objects, which are keys in RocksDB.

All Implemented Interfaces:

AutoCloseable, Iterator<K>

public class RocksMultiStateKeysIterator<K>
extends Object
implements AutoCloseable, Iterator<K>

Adapter class to bridge between RocksIteratorWrapper and Iterator to iterate over the keys. This class is not thread safe.

Constructor Summary

Constructors

Constructor	Description
RocksMultiStateKeysIterator(List<RocksIteratorWrapper> iterators, List<String> states, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, int keyGroupPrefixBytes, List<Boolean> ambiguousKeyPossibles, byte[] namespaceBytes)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	hasNext()
K	next()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Constructor Detail

RocksMultiStateKeysIterator

public RocksMultiStateKeysIterator(List<RocksIteratorWrapper> iterators,
                                   List<String> states,
                                   @Nonnull
                                   org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer,
                                   int keyGroupPrefixBytes,
                                   List<Boolean> ambiguousKeyPossibles,
                                   @Nonnull
                                   byte[] namespaceBytes)

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<K>

next

public K next()

Specified by:

next in interface Iterator<K>

close

public void close()

Specified by:

close in interface AutoCloseable