Flink Table API & SQL 类型系统 DataType

Posted 2022-05-05 @SmartSi

Flink 版本：1.13.5

由于历史原因，在 Flink 1.9 之前，Flink 的 Table API & SQL 数据类型与 Flink 的 TypeInformation 紧密耦合。TypeInformation 主要用于 DataStream 和 DataSet API 中，为系统序列化和反序列化基于 JVM 的对象提供必要的信息。

但是，TypeInformation 原本的设计目的并不能表示不同实际 JVM 类的逻辑类型。因此 SQL 的标准类型很难与这种抽象进行映射。此外，某些类型也不符合 SQL 标准。从 Flink 1.9 开始，Table API & SQL 将获得一个新的类型系统 DataType。

1. 新的数据类型 DataType

Table API & SQL 中新的数据类型 DataType 描述了 Table 生态系统中值的逻辑类型，可以用来声明操作的输入和输出类型。Flink 的数据类型与 SQL 标准的数据类型比较相似，同时也支持 NULL/NOT NULL，例如如下所示：

• INT
• INT NOT NULL
• INTERVAL DAY TO SECOND(3)
• ROW<myField ARRAY, myOtherField TIMESTAMP(3)>

在使用基于 JVM API 编写 Table API、定义 Connector、Catalogs 或者自定义函数中，需要使用 org.apache.flink.table.types.DataType 数据类型的实例。

1.1 作用

DataType 主要有两个作用：

• 声明逻辑类型&