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

Class MapDataSerializer

  • All Implemented Interfaces:
    Serializable
    @Internal
public class MapDataSerializer
extends org.apache.flink.table.runtime.typeutils.MapDataSerializer
    A TypeSerializer for MapData. It should be noted that the header will not be encoded. Currently Python doesn't support BinaryMapData natively, so we can't use BaseArraySerializer directly.
    See Also:
    Serialized Form

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description
      static class  MapDataSerializer.BaseMapSerializerSnapshot
      TypeSerializerSnapshot for MapDataSerializer.

      • Nested classes/interfaces inherited from class org.apache.flink.table.runtime.typeutils.MapDataSerializer

        org.apache.flink.table.runtime.typeutils.MapDataSerializer.MapDataSerializerSnapshot

    • Constructor Summary

      Constructors 
      Constructor Description
      MapDataSerializer​(org.apache.flink.table.types.logical.LogicalType keyType, org.apache.flink.table.types.logical.LogicalType valueType, org.apache.flink.api.common.typeutils.TypeSerializer keyTypeSerializer, org.apache.flink.api.common.typeutils.TypeSerializer valueTypeSerializer)  

    • 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 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()  
      void serialize​(org.apache.flink.table.data.MapData map, org.apache.flink.core.memory.DataOutputView target)  
      org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.flink.table.data.MapData> snapshotConfiguration()  

      • Methods inherited from class org.apache.flink.table.runtime.typeutils.MapDataSerializer

        copy, copy, createInstance, equals, getKeySerializer, getLength, getValueSerializer, hashCode, isImmutableType, toBinaryMap

    • Constructor Detail

      • MapDataSerializer

        public MapDataSerializer​(org.apache.flink.table.types.logical.LogicalType keyType,
                         org.apache.flink.table.types.logical.LogicalType valueType,
                         org.apache.flink.api.common.typeutils.TypeSerializer keyTypeSerializer,
                         org.apache.flink.api.common.typeutils.TypeSerializer valueTypeSerializer)

    • Method Detail

      • serialize

        public void serialize​(org.apache.flink.table.data.MapData map,
                      org.apache.flink.core.memory.DataOutputView target)
               throws IOException
        Overrides:
        serialize in class org.apache.flink.table.runtime.typeutils.MapDataSerializer
        Throws:
        IOException

      • deserialize

        public org.apache.flink.table.data.MapData deserialize​(org.apache.flink.core.memory.DataInputView source)
                                                throws IOException
        Overrides:
        deserialize in class org.apache.flink.table.runtime.typeutils.MapDataSerializer
        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
        Overrides:
        deserialize in class org.apache.flink.table.runtime.typeutils.MapDataSerializer
        Throws:
        IOException

      • copy

        public void copy​(org.apache.flink.core.memory.DataInputView source,
                 org.apache.flink.core.memory.DataOutputView target)
          throws IOException
        Overrides:
        copy in class org.apache.flink.table.runtime.typeutils.MapDataSerializer
        Throws:
        IOException

      • duplicate

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

      • snapshotConfiguration

        public org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.flink.table.data.MapData> snapshotConfiguration()
        Overrides:
        snapshotConfiguration in class org.apache.flink.table.runtime.typeutils.MapDataSerializer