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

Class RocksStatesPerKeyGroupMergeIterator

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, org.apache.flink.runtime.state.KeyValueStateIterator

public class RocksStatesPerKeyGroupMergeIterator
extends Object
implements org.apache.flink.runtime.state.KeyValueStateIterator

Iterator that merges multiple RocksDB iterators to partition all states into contiguous key-groups. The resulting iteration sequence is ordered by (key-group, kv-state).

Constructor Summary

Constructors

Constructor	Description
RocksStatesPerKeyGroupMergeIterator(org.apache.flink.core.fs.CloseableRegistry closeableRegistry, List<org.apache.flink.api.java.tuple.Tuple2<RocksIteratorWrapper,Integer>> kvStateIterators, List<SingleStateIterator> heapPriorityQueueIterators, int keyGroupPrefixByteCount)	Creates a new RocksStatesPerKeyGroupMergeIterator.

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	isNewKeyGroup()
boolean	isNewKeyValueState()
boolean	isValid()
byte[]	key()
int	keyGroup()
int	kvStateId()
void	next()
byte[]	value()

Methods inherited from class java.lang.Object

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

Constructor Detail

RocksStatesPerKeyGroupMergeIterator

public RocksStatesPerKeyGroupMergeIterator(org.apache.flink.core.fs.CloseableRegistry closeableRegistry,
                                           List<org.apache.flink.api.java.tuple.Tuple2<RocksIteratorWrapper,Integer>> kvStateIterators,
                                           List<SingleStateIterator> heapPriorityQueueIterators,
                                           int keyGroupPrefixByteCount)
                                    throws IOException

Creates a new RocksStatesPerKeyGroupMergeIterator. The iterator takes ownership of passed in resources, such as the ReadOptions, and becomes responsible for closing them.

Throws:

IOException

Method Detail

next

public void next()

Specified by:

next in interface org.apache.flink.runtime.state.KeyValueStateIterator

keyGroup

public int keyGroup()

Specified by:

keyGroup in interface org.apache.flink.runtime.state.KeyValueStateIterator

key

public byte[] key()

Specified by:

key in interface org.apache.flink.runtime.state.KeyValueStateIterator

value

public byte[] value()

Specified by:

value in interface org.apache.flink.runtime.state.KeyValueStateIterator

kvStateId

public int kvStateId()

Specified by:

kvStateId in interface org.apache.flink.runtime.state.KeyValueStateIterator

isNewKeyValueState

public boolean isNewKeyValueState()

Specified by:

isNewKeyValueState in interface org.apache.flink.runtime.state.KeyValueStateIterator

isNewKeyGroup

public boolean isNewKeyGroup()

Specified by:

isNewKeyGroup in interface org.apache.flink.runtime.state.KeyValueStateIterator

isValid

public boolean isValid()

Specified by:

isValid in interface org.apache.flink.runtime.state.KeyValueStateIterator

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.flink.runtime.state.KeyValueStateIterator