Class AbstractRocksStateKeysIterator<K>
- java.lang.Object
-
- org.apache.flink.state.rocksdb.iterator.AbstractRocksStateKeysIterator<K>
-
- Type Parameters:
K
- the type of the iterated objects, which are keys in RocksDB.
- All Implemented Interfaces:
AutoCloseable
- Direct Known Subclasses:
RocksStateKeysAndNamespaceIterator
,RocksStateKeysIterator
@Internal public abstract class AbstractRocksStateKeysIterator<K> extends Object implements AutoCloseable
Base class for iterators over RocksDB column families.
-
-
Field Summary
Fields Modifier and Type Field Description protected boolean
ambiguousKeyPossible
protected DataInputDeserializer
byteArrayDataInputView
protected RocksIteratorWrapper
iterator
protected int
keyGroupPrefixBytes
protected TypeSerializer<K>
keySerializer
protected String
state
-
Constructor Summary
Constructors Constructor Description AbstractRocksStateKeysIterator(RocksIteratorWrapper iterator, String state, TypeSerializer<K> keySerializer, int keyGroupPrefixBytes, boolean ambiguousKeyPossible)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
protected K
deserializeKey(byte[] keyBytes, DataInputDeserializer readView)
-
-
-
Field Detail
-
iterator
@Nonnull protected final RocksIteratorWrapper iterator
-
state
@Nonnull protected final String state
-
keySerializer
@Nonnull protected final TypeSerializer<K> keySerializer
-
ambiguousKeyPossible
protected final boolean ambiguousKeyPossible
-
keyGroupPrefixBytes
protected final int keyGroupPrefixBytes
-
byteArrayDataInputView
protected final DataInputDeserializer byteArrayDataInputView
-
-
Constructor Detail
-
AbstractRocksStateKeysIterator
public AbstractRocksStateKeysIterator(@Nonnull RocksIteratorWrapper iterator, @Nonnull String state, @Nonnull TypeSerializer<K> keySerializer, int keyGroupPrefixBytes, boolean ambiguousKeyPossible)
-
-
Method Detail
-
deserializeKey
protected K deserializeKey(byte[] keyBytes, DataInputDeserializer readView) throws IOException
- Throws:
IOException
-
close
public void close()
- Specified by:
close
in interfaceAutoCloseable
-
-