Package org.apache.flink.runtime.state.v2

Class InternalKeyedState<K,​V>

  • Type Parameters:
    K - The type of key the state is associated to.
    V - The type of values kept internally in state.
    All Implemented Interfaces:
    org.apache.flink.api.common.state.v2.State
    Direct Known Subclasses:
    InternalAggregatingState, InternalListState, InternalMapState, InternalReducingState, InternalValueState
    @Internal
public abstract class InternalKeyedState<K,​V>
extends Object
implements org.apache.flink.api.common.state.v2.State
    The InternalKeyedState is the root of the internal state type hierarchy, similar to the State being the root of the public API state hierarchy.

    The public API state hierarchy is intended to be programmed against by Flink applications. The internal state hierarchy holds all the auxiliary methods that communicates with AsyncExecutionController and not intended to be used by user applications.

    • Constructor Detail

      • InternalKeyedState

        public InternalKeyedState​(StateRequestHandler stateRequestHandler,
                          StateDescriptor<V> stateDescriptor)
        Creates a new InternalKeyedState with the given asyncExecutionController and stateDescriptor.

    • Method Detail

      • handleRequest

        protected final <IN,​OUT> org.apache.flink.api.common.state.v2.StateFuture<OUT> handleRequest​(StateRequestType stateRequestType,
                                                                                                   IN payload)
        Submit a state request to AEC.
        Parameters:
        stateRequestType - the type of this request.
        payload - the payload input for this request.
        Returns:
        the state future.

      • asyncClear

        public final org.apache.flink.api.common.state.v2.StateFuture<Void> asyncClear()
        Specified by:
        asyncClear in interface org.apache.flink.api.common.state.v2.State

      • getStateDescriptor

        public StateDescriptor<V> getStateDescriptor()
        Return specific StateDescriptor.

      • getValueSerializer

        public org.apache.flink.api.common.typeutils.TypeSerializer<V> getValueSerializer()
        Return related value serializer.