public class RocksStatesPerKeyGroupMergeIterator extends Object implements AutoCloseable
Constructor and Description |
---|
RocksStatesPerKeyGroupMergeIterator(List<Tuple2<RocksIteratorWrapper,Integer>> kvStateIterators,
int keyGroupPrefixByteCount) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
boolean |
isNewKeyGroup()
Indicates if current key starts a new key-group, i.e.
|
boolean |
isNewKeyValueState()
Indicates if current key starts a new k/v-state, i.e.
|
boolean |
isValid()
Check if the iterator is still valid.
|
byte[] |
key() |
int |
keyGroup() |
int |
kvStateId() |
void |
next()
Advances the iterator.
|
byte[] |
value() |
public RocksStatesPerKeyGroupMergeIterator(List<Tuple2<RocksIteratorWrapper,Integer>> kvStateIterators, int keyGroupPrefixByteCount)
public void next()
public int keyGroup()
public byte[] key()
public byte[] value()
public int kvStateId()
public boolean isNewKeyValueState()
public boolean isNewKeyGroup()
public boolean isValid()
key()
, value()
, etc. as
well as next()
should only be called if valid returned true. Should be checked after
each call to next()
before accessing iterator state.public void close()
close
in interface AutoCloseable
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.