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

Class AbstractRocksStateKeysIterator<K>

java.lang.Object

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

Type Parameters:

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

All Implemented Interfaces:

AutoCloseable

Direct Known Subclasses:

RocksStateKeysAndNamespaceIterator, RocksStateKeysIterator

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

Base class for iterators over RocksDB column families.

Field Summary

Fields

Modifier and Type	Field	Description
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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close()
protected K	deserializeKey(byte[] keyBytes, org.apache.flink.core.memory.DataInputDeserializer readView)
static boolean	isMatchingNameSpace(byte[] key, int namespaceBytesStartPos, byte[] namespaceBytes)

Methods inherited from class java.lang.Object

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

Field Detail

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

Constructor Detail

AbstractRocksStateKeysIterator

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

Method Detail

deserializeKey

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

Throws:

IOException

close

public void close()

Specified by:

close in interface AutoCloseable

isMatchingNameSpace

public static boolean isMatchingNameSpace(@Nonnull
                                          byte[] key,
                                          int namespaceBytesStartPos,
                                          @Nonnull
                                          byte[] namespaceBytes)