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

类 RocksStatesPerKeyGroupMergeIterator

java.lang.Object

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

所有已实现的接口:

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).

构造器概要

构造器

构造器和说明
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.

方法概要

限定符和类型	方法和说明
void	close()
boolean	isNewKeyGroup()
boolean	isNewKeyValueState()
boolean	isValid()
byte[]	key()
int	keyGroup()
int	kvStateId()
void	next()
byte[]	value()

从类继承的方法 java.lang.Object

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

构造器详细资料

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.

抛出:

IOException

方法详细资料

next

public void next()

指定者:

next 在接口中 org.apache.flink.runtime.state.KeyValueStateIterator

keyGroup

public int keyGroup()

指定者:

keyGroup 在接口中 org.apache.flink.runtime.state.KeyValueStateIterator

key

public byte[] key()

指定者:

key 在接口中 org.apache.flink.runtime.state.KeyValueStateIterator

value

public byte[] value()

指定者:

value 在接口中 org.apache.flink.runtime.state.KeyValueStateIterator

kvStateId

public int kvStateId()

指定者:

kvStateId 在接口中 org.apache.flink.runtime.state.KeyValueStateIterator

isNewKeyValueState

public boolean isNewKeyValueState()

指定者:

isNewKeyValueState 在接口中 org.apache.flink.runtime.state.KeyValueStateIterator

isNewKeyGroup

public boolean isNewKeyGroup()

指定者:

isNewKeyGroup 在接口中 org.apache.flink.runtime.state.KeyValueStateIterator

isValid

public boolean isValid()

指定者:

isValid 在接口中 org.apache.flink.runtime.state.KeyValueStateIterator

close

public void close()

指定者:

close 在接口中 AutoCloseable

指定者:

close 在接口中 org.apache.flink.runtime.state.KeyValueStateIterator