Package org.apache.flink.state.forst

Class ForStListIterator<V>

java.lang.Object

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

org.apache.flink.state.forst.ForStListIterator<V>

All Implemented Interfaces:

StateIterator<V>

public class ForStListIterator<V>
extends AbstractStateIterator<V>

The forst implementation for list iterator.

Constructor Summary

Constructors

Constructor	Description
ForStListIterator(State originalState, StateRequestType requestType, StateRequestHandler stateHandler, Collection<V> partialResult)

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

ForStListIterator

public ForStListIterator(State originalState,
                         StateRequestType requestType,
                         StateRequestHandler stateHandler,
                         Collection<V> partialResult)

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<V>

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<V>

Returns:

the packed payload for next loading.