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:

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

public class ForStListIterator<V>
extends org.apache.flink.runtime.asyncprocessing.AbstractStateIterator<V>

The forst implementation for list iterator.

Constructor Summary

Constructors

Constructor	Description
ForStListIterator(org.apache.flink.api.common.state.v2.State originalState, org.apache.flink.runtime.asyncprocessing.StateRequestType requestType, org.apache.flink.runtime.asyncprocessing.StateRequestHandler stateHandler, Collection<V> partialResult)

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

ForStListIterator

public ForStListIterator(org.apache.flink.api.common.state.v2.State originalState,
                         org.apache.flink.runtime.asyncprocessing.StateRequestType requestType,
                         org.apache.flink.runtime.asyncprocessing.StateRequestHandler stateHandler,
                         Collection<V> partialResult)

Method Detail

hasNextLoading

public boolean hasNextLoading()

Specified by:

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

Specified by:

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

nextPayloadForContinuousLoading

protected Object nextPayloadForContinuousLoading()

Specified by:

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