Class InternalAggregatingState<K,​IN,​ACC,​OUT>

  • Type Parameters:
    K - The type of key the state is associated to.
    IN - The type of the values that are added into the state.
    ACC - TThe type of the accumulator (intermediate aggregation state).
    OUT - The type of the values that are returned from the state.
    All Implemented Interfaces:
    org.apache.flink.api.common.state.v2.AggregatingState<IN,​OUT>, org.apache.flink.api.common.state.v2.AppendingState<IN,​OUT>, org.apache.flink.api.common.state.v2.MergingState<IN,​OUT>, org.apache.flink.api.common.state.v2.State

    public class InternalAggregatingState<K,​IN,​ACC,​OUT>
    extends InternalKeyedState<K,​ACC>
    implements org.apache.flink.api.common.state.v2.AggregatingState<IN,​OUT>
    The default implementation of AggregatingState, which delegates all async requests to StateRequestHandler.
    • Field Detail

      • aggregateFunction

        protected final org.apache.flink.api.common.functions.AggregateFunction<IN,​ACC,​OUT> aggregateFunction
    • Constructor Detail

      • InternalAggregatingState

        public InternalAggregatingState​(StateRequestHandler stateRequestHandler,
                                        AggregatingStateDescriptor<IN,​ACC,​OUT> stateDescriptor)
        Creates a new InternalKeyedState with the given asyncExecutionController and stateDescriptor.
        Parameters:
        stateRequestHandler - The async request handler for handling all requests.
        stateDescriptor - The properties of the state.
    • Method Detail

      • asyncGet

        public org.apache.flink.api.common.state.v2.StateFuture<OUT> asyncGet()
        Specified by:
        asyncGet in interface org.apache.flink.api.common.state.v2.AppendingState<K,​IN>
      • asyncAdd

        public org.apache.flink.api.common.state.v2.StateFuture<Void> asyncAdd​(IN value)
        Specified by:
        asyncAdd in interface org.apache.flink.api.common.state.v2.AppendingState<K,​IN>