95-910-165-源码-FlinkSQL-Flink SQL 中的时间属性

Posted 2021-10-31 九师兄

1.美图

2.时间属性概览

​ 在 Flink SQL 中，表可以提供逻辑上的时间属性用于获取时间信息，时间属性可以是处理时间也可以是事件时间。在声明一张表的时候，时间属性可以在表的 schema 中定义。有些特定的操作，如窗口关联和窗口聚合操作必须基于时间属性字段，因而时间属性可以被看作一种特殊的字段类型；但是时间属性可以当作常规的时间戳字段来使用，一旦需要在计算中使用到时间属性，就需要“物化”（materialized）时间属性，时间属性字段就会被转换成一个常规的时间戳类型。被物化后的时间属性不再与 Flink 的时间系统和水位线相关联，因而也就不可以再应用在基于时间的操作中。

在 Flink SQL 的类型系统中，时间属性和常规的时间戳类型共用同样的逻辑类型 TimestampType，但是通过 TimestampKind 进行区分：

public enum TimestampKind