public final class RocksQueueIterator extends Object implements SingleStateIterator
Constructor and Description |
---|
RocksQueueIterator(HeapPriorityQueueStateSnapshot<?> queuesSnapshot,
KeyGroupRange keyGroupRange,
int keyGroupPrefixBytes,
int kvStateId) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
int |
getKvStateId() |
boolean |
isValid() |
byte[] |
key() |
void |
next() |
byte[] |
value() |
public RocksQueueIterator(HeapPriorityQueueStateSnapshot<?> queuesSnapshot, KeyGroupRange keyGroupRange, int keyGroupPrefixBytes, int kvStateId)
public void next()
next
in interface SingleStateIterator
public boolean isValid()
isValid
in interface SingleStateIterator
public byte[] key()
key
in interface SingleStateIterator
public byte[] value()
value
in interface SingleStateIterator
public int getKvStateId()
getKvStateId
in interface SingleStateIterator
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in interface SingleStateIterator
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.