I am writing Flink applications in Java and I need to do data type
conversions between SQL/Table `DataType` and `TypeInformation`. According
to Flink's documentation, type mapping methods in  TypeConversions
<https://github.com/apache/flink/blob/master/flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/utils/TypeConversions.java>
class are all deprecated; However it is not clear how a developer should
perform such a mapping correctly, given that there is no straightforward
data type mapping between DataType/Logical types (instances of DataTypes
class
<https://github.com/apache/flink/blob/master/flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/DataTypes.java>)
and `TypeInformation` (instances of Types class
<https://github.com/apache/flink/blob/master/flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java>).
Any suggestions/clarifications?

Reply via email to