Package org.apache.flink.table.runtime.typeutils

Class MapDataSerializer

  • All Implemented Interfaces:
    Serializable
    @Internal
public class MapDataSerializer
extends org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.MapData>
    Serializer for MapData.
    See Also:
    Serialized Form

    • Constructor Summary

      Constructors 
      Constructor Description
      MapDataSerializer​(org.apache.flink.table.types.logical.LogicalType keyType, org.apache.flink.table.types.logical.LogicalType valueType)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void copy​(org.apache.flink.core.memory.DataInputView source, org.apache.flink.core.memory.DataOutputView target)  
      org.apache.flink.table.data.MapData copy​(org.apache.flink.table.data.MapData from)
      NOTE: Map should be a HashMap, when we insert the key/value pairs of the TreeMap into a HashMap, problems maybe occur.
      org.apache.flink.table.data.MapData copy​(org.apache.flink.table.data.MapData from, org.apache.flink.table.data.MapData reuse)  
      org.apache.flink.table.data.MapData createInstance()  
      org.apache.flink.table.data.MapData deserialize​(org.apache.flink.core.memory.DataInputView source)  
      org.apache.flink.table.data.MapData deserialize​(org.apache.flink.table.data.MapData reuse, org.apache.flink.core.memory.DataInputView source)  
      org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.MapData> duplicate()  
      boolean equals​(Object o)  
      org.apache.flink.api.common.typeutils.TypeSerializer getKeySerializer()  
      int getLength()  
      org.apache.flink.api.common.typeutils.TypeSerializer getValueSerializer()  
      int hashCode()  
      boolean isImmutableType()  
      void serialize​(org.apache.flink.table.data.MapData record, org.apache.flink.core.memory.DataOutputView target)  
      org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.flink.table.data.MapData> snapshotConfiguration()  
      org.apache.flink.table.data.binary.BinaryMapData toBinaryMap​(org.apache.flink.table.data.MapData from)  

    • Constructor Detail

      • MapDataSerializer

        public MapDataSerializer​(org.apache.flink.table.types.logical.LogicalType keyType,
                         org.apache.flink.table.types.logical.LogicalType valueType)

    • Method Detail

      • isImmutableType

        public boolean isImmutableType()
        Specified by:
        isImmutableType in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.MapData>

      • duplicate

        public org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.MapData> duplicate()
        Specified by:
        duplicate in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.MapData>

      • createInstance

        public org.apache.flink.table.data.MapData createInstance()
        Specified by:
        createInstance in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.MapData>

      • copy

        public org.apache.flink.table.data.MapData copy​(org.apache.flink.table.data.MapData from)
        NOTE: Map should be a HashMap, when we insert the key/value pairs of the TreeMap into a HashMap, problems maybe occur.
        Specified by:
        copy in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.MapData>

      • copy

        public org.apache.flink.table.data.MapData copy​(org.apache.flink.table.data.MapData from,
                                                org.apache.flink.table.data.MapData reuse)
        Specified by:
        copy in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.MapData>

      • getLength

        public int getLength()
        Specified by:
        getLength in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.MapData>

      • serialize

        public void serialize​(org.apache.flink.table.data.MapData record,
                      org.apache.flink.core.memory.DataOutputView target)
               throws IOException
        Specified by:
        serialize in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.MapData>
        Throws:
        IOException

      • toBinaryMap

        public org.apache.flink.table.data.binary.BinaryMapData toBinaryMap​(org.apache.flink.table.data.MapData from)

      • deserialize

        public org.apache.flink.table.data.MapData deserialize​(org.apache.flink.core.memory.DataInputView source)
                                                throws IOException
        Specified by:
        deserialize in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.MapData>
        Throws:
        IOException

      • deserialize

        public org.apache.flink.table.data.MapData deserialize​(org.apache.flink.table.data.MapData reuse,
                                                       org.apache.flink.core.memory.DataInputView source)
                                                throws IOException
        Specified by:
        deserialize in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.MapData>
        Throws:
        IOException

      • copy

        public void copy​(org.apache.flink.core.memory.DataInputView source,
                 org.apache.flink.core.memory.DataOutputView target)
          throws IOException
        Specified by:
        copy in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.MapData>
        Throws:
        IOException

      • equals

        public boolean equals​(Object o)
        Specified by:
        equals in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.MapData>

      • hashCode

        public int hashCode()
        Specified by:
        hashCode in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.MapData>

      • getKeySerializer

        @VisibleForTesting
public org.apache.flink.api.common.typeutils.TypeSerializer getKeySerializer()

      • getValueSerializer

        @VisibleForTesting
public org.apache.flink.api.common.typeutils.TypeSerializer getValueSerializer()

      • snapshotConfiguration

        public org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.flink.table.data.MapData> snapshotConfiguration()
        Specified by:
        snapshotConfiguration in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.MapData>