Class MapMapConverter<K,V>
- java.lang.Object
-
- org.apache.flink.table.data.conversion.MapMapConverter<K,V>
-
- All Implemented Interfaces:
Serializable,DataStructureConverter<org.apache.flink.table.data.MapData,Map<K,V>>
@Internal public class MapMapConverter<K,V> extends Object implements DataStructureConverter<org.apache.flink.table.data.MapData,Map<K,V>>
- See Also:
- Serialized Form
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static MapMapConverter<?,?>createForMapType(org.apache.flink.table.types.DataType dataType)static MapMapConverter<?,?>createForMultisetType(org.apache.flink.table.types.DataType dataType)voidopen(ClassLoader classLoader)Map<K,V>toExternal(org.apache.flink.table.data.MapData internal)Converts to external data structure.org.apache.flink.table.data.MapDatatoInternal(Map<K,V> external)Converts to internal data structure.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.flink.table.data.conversion.DataStructureConverter
isIdentityConversion, toExternalOrNull, toInternalOrNull
-
-
-
-
Method Detail
-
open
public void open(ClassLoader classLoader)
- Specified by:
openin interfaceDataStructureConverter<K,V>
-
toInternal
public org.apache.flink.table.data.MapData toInternal(Map<K,V> external)
Description copied from interface:DataStructureConverterConverts to internal data structure.Note: Parameter must not be null. Output must not be null.
- Specified by:
toInternalin interfaceDataStructureConverter<K,V>
-
toExternal
public Map<K,V> toExternal(org.apache.flink.table.data.MapData internal)
Description copied from interface:DataStructureConverterConverts to external data structure.Note: Parameter must not be null. Output must not be null.
- Specified by:
toExternalin interfaceDataStructureConverter<K,V>
-
createForMapType
public static MapMapConverter<?,?> createForMapType(org.apache.flink.table.types.DataType dataType)
-
createForMultisetType
public static MapMapConverter<?,?> createForMultisetType(org.apache.flink.table.types.DataType dataType)
-
-