K
- the type of the iterated objects, which are keys in RocksDB.@Internal public abstract class AbstractRocksStateKeysIterator<K> extends Object implements AutoCloseable
Modifier and Type | Field and Description |
---|---|
protected boolean |
ambiguousKeyPossible |
protected DataInputDeserializer |
byteArrayDataInputView |
protected RocksIteratorWrapper |
iterator |
protected int |
keyGroupPrefixBytes |
protected TypeSerializer<K> |
keySerializer |
protected String |
state |
Constructor and Description |
---|
AbstractRocksStateKeysIterator(RocksIteratorWrapper iterator,
String state,
TypeSerializer<K> keySerializer,
int keyGroupPrefixBytes,
boolean ambiguousKeyPossible) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected K |
deserializeKey(byte[] keyBytes,
DataInputDeserializer readView) |
@Nonnull protected final RocksIteratorWrapper iterator
@Nonnull protected final TypeSerializer<K> keySerializer
protected final boolean ambiguousKeyPossible
protected final int keyGroupPrefixBytes
protected final DataInputDeserializer byteArrayDataInputView
public AbstractRocksStateKeysIterator(@Nonnull RocksIteratorWrapper iterator, @Nonnull String state, @Nonnull TypeSerializer<K> keySerializer, int keyGroupPrefixBytes, boolean ambiguousKeyPossible)
protected K deserializeKey(byte[] keyBytes, DataInputDeserializer readView) throws IOException
IOException
public void close()
close
in interface AutoCloseable
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.