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

类 AbstractRocksStateKeysIterator<K>

java.lang.Object

org.apache.flink.contrib.streaming.state.iterator.AbstractRocksStateKeysIterator<K>

类型参数:

K - the type of the iterated objects, which are keys in RocksDB.

所有已实现的接口:

AutoCloseable

直接已知子类:

RocksStateKeysAndNamespaceIterator, RocksStateKeysIterator

@Internal
public abstract class AbstractRocksStateKeysIterator<K>
extends Object
implements AutoCloseable

Base class for iterators over RocksDB column families.

字段概要

字段

限定符和类型	字段和说明
protected boolean	ambiguousKeyPossible
protected org.apache.flink.core.memory.DataInputDeserializer	byteArrayDataInputView
protected RocksIteratorWrapper	iterator
protected int	keyGroupPrefixBytes
protected org.apache.flink.api.common.typeutils.TypeSerializer<K>	keySerializer
protected String	state

构造器概要

构造器

构造器和说明
AbstractRocksStateKeysIterator(RocksIteratorWrapper iterator, String state, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, int keyGroupPrefixBytes, boolean ambiguousKeyPossible)

方法概要

限定符和类型	方法和说明
void	close()
protected K	deserializeKey(byte[] keyBytes, org.apache.flink.core.memory.DataInputDeserializer readView)

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

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

字段详细资料

iterator

@Nonnull
protected final RocksIteratorWrapper iterator

state

@Nonnull
protected final String state

keySerializer

@Nonnull
protected final org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer

ambiguousKeyPossible

protected final boolean ambiguousKeyPossible

keyGroupPrefixBytes

protected final int keyGroupPrefixBytes

byteArrayDataInputView

protected final org.apache.flink.core.memory.DataInputDeserializer byteArrayDataInputView

构造器详细资料

AbstractRocksStateKeysIterator

public AbstractRocksStateKeysIterator(@Nonnull
                                      RocksIteratorWrapper iterator,
                                      @Nonnull
                                      String state,
                                      @Nonnull
                                      org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer,
                                      int keyGroupPrefixBytes,
                                      boolean ambiguousKeyPossible)

方法详细资料

deserializeKey

protected K deserializeKey(byte[] keyBytes,
                           org.apache.flink.core.memory.DataInputDeserializer readView)
                    throws IOException

抛出:

IOException

close

public void close()

指定者:

close 在接口中 AutoCloseable