Package org.apache.flink.state.api.input.operator.window

Interface WindowContents<S extends org.apache.flink.api.common.state.State,​IN>

  • Type Parameters:
    S - The initial state type.
    IN - The data in state.
    All Superinterfaces:
    Serializable
    Functional Interface:
    This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
    @FunctionalInterface
public interface WindowContents<S extends org.apache.flink.api.common.state.State,​IN>
extends Serializable
    An abstraction for transforming any State type into an iterable over its contents.

    • Method Detail

      • reducingState

        static <T> WindowContents<org.apache.flink.api.common.state.ReducingState<T>,​T> reducingState()

      • aggregatingState

        static <IN,​OUT> WindowContents<org.apache.flink.api.common.state.AggregatingState<IN,​OUT>,​OUT> aggregatingState()

      • listState

        static <T> WindowContents<org.apache.flink.api.common.state.ListState<T>,​T> listState()