Package org.apache.flink.table.runtime.dataview

Interface StateDataViewStore

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      org.apache.flink.api.common.functions.RuntimeContext getRuntimeContext()  
      <N,​EE>
      StateListView<N,​EE>      		 getStateListView​(String stateName, org.apache.flink.api.common.typeutils.TypeSerializer<EE> elementSerializer)
      Creates a state list view.
      <N,​EK,​EV>
      StateMapView<N,​EK,​EV>      		 getStateMapView​(String stateName, boolean supportNullKey, org.apache.flink.api.common.typeutils.TypeSerializer<EK> keySerializer, org.apache.flink.api.common.typeutils.TypeSerializer<EV> valueSerializer)
      Creates a state map view.

    • Method Detail

      • getStateMapView

        <N,​EK,​EV> StateMapView<N,​EK,​EV> getStateMapView​(String stateName,
                                                                        boolean supportNullKey,
                                                                        org.apache.flink.api.common.typeutils.TypeSerializer<EK> keySerializer,
                                                                        org.apache.flink.api.common.typeutils.TypeSerializer<EV> valueSerializer)
                                                                 throws Exception
        Creates a state map view.
        Type Parameters:
        N - Type of the namespace
        EK - External type of the keys in the map state
        EV - External type of the values in the map state
        Parameters:
        stateName - The name of underlying state of the map view
        supportNullKey - Whether the null key should be supported
        keySerializer - The key serializer
        valueSerializer - The value serializer
        Returns:
        a keyed map state
        Throws:
        Exception

      • getStateListView

        <N,​EE> StateListView<N,​EE> getStateListView​(String stateName,
                                                        org.apache.flink.api.common.typeutils.TypeSerializer<EE> elementSerializer)
                                                 throws Exception
        Creates a state list view.
        Type Parameters:
        N - Type of the namespace
        EE - External type of the elements in the list state
        Parameters:
        stateName - The name of underlying state of the list view
        elementSerializer - The element serializer
        Returns:
        a keyed list state
        Throws:
        Exception

      • getRuntimeContext

        org.apache.flink.api.common.functions.RuntimeContext getRuntimeContext()