Class MapTypeDescriptorImpl<K,​V>

  • Type Parameters:
    K - type for which key TypeInformation is created.
    V - type for which value TypeInformation is created.
    All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.typeinfo.TypeDescriptor<Map<K,​V>>

    @Internal
    public class MapTypeDescriptorImpl<K,​V>
    extends Object
    implements org.apache.flink.api.common.typeinfo.TypeDescriptor<Map<K,​V>>
    Implementation of TypeDescriptor to create MapTypeInfo. Note that this class is initiated via reflection. So, changing its path or constructor will brake tests.
    See Also:
    Serialized Form
    • Constructor Detail

      • MapTypeDescriptorImpl

        public MapTypeDescriptorImpl​(org.apache.flink.api.common.typeinfo.TypeDescriptor<K> keyTypeDescriptor,
                                     org.apache.flink.api.common.typeinfo.TypeDescriptor<V> valueTypeDescriptor)
    • Method Detail

      • getTypeClass

        public Class<Map<K,​V>> getTypeClass()
        Specified by:
        getTypeClass in interface org.apache.flink.api.common.typeinfo.TypeDescriptor<K>
      • getKeyTypeClass

        public Class<K> getKeyTypeClass()
      • getKeyValueClass

        public Class<V> getKeyValueClass()