Package org.apache.flink.core.state

Interface InternalStateIterator<T>

  • All Superinterfaces:
    org.apache.flink.api.common.state.v2.StateIterator<T>
    @Internal
public interface InternalStateIterator<T>
extends org.apache.flink.api.common.state.v2.StateIterator<T>
    The Internal definition of InternalStateIterator, add some method that will be used by framework.

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      Iterable<T> getCurrentCache()
      Return the already loaded elements in cache.
      boolean hasNextLoading()
      Return whether this iterator has more elements to load.

      • Methods inherited from interface org.apache.flink.api.common.state.v2.StateIterator

        isEmpty, onNext, onNext

    • Method Detail

      • hasNextLoading

        boolean hasNextLoading()
        Return whether this iterator has more elements to load.

      • getCurrentCache

        Iterable<T> getCurrentCache()
        Return the already loaded elements in cache.