Package org.apache.flink.state.forst.sync

Class AbstractForStStateKeysIterator<K>

java.lang.Object

org.apache.flink.state.forst.sync.AbstractForStStateKeysIterator<K>

Type Parameters:

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

All Implemented Interfaces:

AutoCloseable

Direct Known Subclasses:

ForStStateKeysAndNamespaceIterator, ForStStateKeysIterator

@Internal
public abstract class AbstractForStStateKeysIterator<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 DataInputDeserializer	byteArrayDataInputView
protected ForStIteratorWrapper	iterator
protected int	keyGroupPrefixBytes
protected TypeSerializer<K>	keySerializer
protected String	state

Constructor Summary

Constructors

Constructor	Description
AbstractForStStateKeysIterator(ForStIteratorWrapper iterator, String state, TypeSerializer<K> keySerializer, int keyGroupPrefixBytes, boolean ambiguousKeyPossible)

Method Summary

Modifier and Type	Method	Description
void	close()
protected K	deserializeKey(byte[] keyBytes, DataInputDeserializer readView)

Methods inherited from class java.lang.Object

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

Field Detail

iterator

@Nonnull
protected final ForStIteratorWrapper iterator

state

@Nonnull
protected final String state

keySerializer

@Nonnull
protected final TypeSerializer<K> keySerializer

ambiguousKeyPossible

protected final boolean ambiguousKeyPossible

keyGroupPrefixBytes

protected final int keyGroupPrefixBytes

byteArrayDataInputView

protected final DataInputDeserializer byteArrayDataInputView

Constructor Detail

AbstractForStStateKeysIterator

public AbstractForStStateKeysIterator(@Nonnull
                                      ForStIteratorWrapper iterator,
                                      @Nonnull
                                      String state,
                                      @Nonnull
                                      TypeSerializer<K> keySerializer,
                                      int keyGroupPrefixBytes,
                                      boolean ambiguousKeyPossible)

Method Detail

deserializeKey

protected K deserializeKey(byte[] keyBytes,
                           DataInputDeserializer readView)
                    throws IOException

Throws:

IOException

close

public void close()

Specified by:

close in interface AutoCloseable