Package org.apache.flink.state.forst

Class ForStMapIterator<T>

java.lang.Object

org.apache.flink.runtime.asyncprocessing.AbstractStateIterator<T>

org.apache.flink.state.forst.ForStMapIterator<T>

All Implemented Interfaces:

org.apache.flink.api.common.state.v2.StateIterator<T>, org.apache.flink.core.state.InternalStateIterator<T>

public class ForStMapIterator<T>
extends org.apache.flink.runtime.asyncprocessing.AbstractStateIterator<T>

The map iterator implementation for ForStDB.

Constructor Summary

Constructors

Constructor	Description
ForStMapIterator(org.apache.flink.api.common.state.v2.State originalState, org.apache.flink.runtime.asyncprocessing.StateRequestType originalRequestType, org.apache.flink.runtime.asyncprocessing.StateRequestType requestType, org.apache.flink.runtime.asyncprocessing.StateRequestHandler stateHandler, Collection<T> partialResult, boolean encounterEnd, org.forstdb.RocksIterator rocksIterator)

Method Summary

Modifier and Type	Method	Description
boolean	hasNextLoading()
protected Object	nextPayloadForContinuousLoading()

Methods inherited from class org.apache.flink.runtime.asyncprocessing.AbstractStateIterator

getCurrentCache, getRequestType, isEmpty, onNext, onNext, onNextSync

Methods inherited from class java.lang.Object

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

Constructor Detail

ForStMapIterator

public ForStMapIterator(org.apache.flink.api.common.state.v2.State originalState,
                        org.apache.flink.runtime.asyncprocessing.StateRequestType originalRequestType,
                        org.apache.flink.runtime.asyncprocessing.StateRequestType requestType,
                        org.apache.flink.runtime.asyncprocessing.StateRequestHandler stateHandler,
                        Collection<T> partialResult,
                        boolean encounterEnd,
                        org.forstdb.RocksIterator rocksIterator)

Method Detail

hasNextLoading

public boolean hasNextLoading()

Specified by:

hasNextLoading in interface org.apache.flink.core.state.InternalStateIterator<T>

Specified by:

hasNextLoading in class org.apache.flink.runtime.asyncprocessing.AbstractStateIterator<T>

nextPayloadForContinuousLoading

protected Object nextPayloadForContinuousLoading()

Specified by:

nextPayloadForContinuousLoading in class org.apache.flink.runtime.asyncprocessing.AbstractStateIterator<T>