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

类 RocksQueueIterator

java.lang.Object

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

所有已实现的接口:

Closeable, AutoCloseable, SingleStateIterator

public final class RocksQueueIterator
extends Object
implements SingleStateIterator

An iterator over heap timers that produces rocks compatible binary format.

构造器概要

构造器

构造器和说明
RocksQueueIterator(org.apache.flink.runtime.state.heap.HeapPriorityQueueStateSnapshot<?> queuesSnapshot, org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, int keyGroupPrefixBytes, int kvStateId)

方法概要

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

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

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

构造器详细资料

RocksQueueIterator

public RocksQueueIterator(org.apache.flink.runtime.state.heap.HeapPriorityQueueStateSnapshot<?> queuesSnapshot,
                          org.apache.flink.runtime.state.KeyGroupRange keyGroupRange,
                          int keyGroupPrefixBytes,
                          int kvStateId)

方法详细资料

next

public void next()

指定者:

next 在接口中 SingleStateIterator

isValid

public boolean isValid()

指定者:

isValid 在接口中 SingleStateIterator

key

public byte[] key()

指定者:

key 在接口中 SingleStateIterator

value

public byte[] value()

指定者:

value 在接口中 SingleStateIterator

getKvStateId

public int getKvStateId()

指定者:

getKvStateId 在接口中 SingleStateIterator

close

public void close()

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable

指定者:

close 在接口中 SingleStateIterator