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:

StateIterator<T>

public class ForStMapIterator<T>
extends AbstractStateIterator<T>

The map iterator implementation for ForStDB.

Constructor Summary

Constructors

Constructor	Description
ForStMapIterator(State originalState, StateRequestType originalRequestType, StateRequestType requestType, StateRequestHandler stateHandler, Collection<T> partialResult, boolean encounterEnd, org.forstdb.RocksIterator rocksIterator)

Method Summary

Modifier and Type	Method	Description
protected boolean	hasNext()	Return whether this iterator has more elements to load besides current cache.
protected Object	nextPayloadForContinuousLoading()	To perform following loading, build and get next payload for the next request.

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

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(State originalState,
                        StateRequestType originalRequestType,
                        StateRequestType requestType,
                        StateRequestHandler stateHandler,
                        Collection<T> partialResult,
                        boolean encounterEnd,
                        org.forstdb.RocksIterator rocksIterator)

Method Detail

hasNext

protected boolean hasNext()

Description copied from class: AbstractStateIterator

Return whether this iterator has more elements to load besides current cache.

Specified by:

hasNext in class AbstractStateIterator<T>

nextPayloadForContinuousLoading

protected Object nextPayloadForContinuousLoading()

Description copied from class: AbstractStateIterator

To perform following loading, build and get next payload for the next request. This will put into StateRequest.getPayload().

Specified by:

nextPayloadForContinuousLoading in class AbstractStateIterator<T>

Returns:

the packed payload for next loading.