本文主要是介绍Table API SQL之时区Time Zone详解,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
目录
数据类型
日期和时间(Date and Time)
日期(DATE)
时间(TIME)
时间戳(TIMESTAMP)
无时区时间戳
有时区时间戳
本地时区时间戳(TIMESTAMP_LTZ)
区间年月(INTERVAL YEAR TO MONTH)
区间日秒(INTERVAL DAY TO SECOND)
时区(Time Zone)
TIMESTAMP类型
TIMESTAMP_LTZ类型
Time Zone应用
决定时间函数的返回值
TIMESTAMP_LTZ字符串表示形式
Time Attributes
Event Time
在DDL中定义
在数据流到表转换期间
Processing Time
在DDL中定义
在数据流到表转换期间
时间属性和时区
处理时间和时区
事件时间和时区
TIMESTAMP上的事件时间属性
TIMESTAMP_LTZ上的事件时间属性
Flink提供了丰富的日期和时间数据类型,包括Date, Time, TIMESTAMP, TIMESTAMP_LTZ, INTERVAL YEAR TO MONTH, INTERVAL DAY TO SECOND。Flink支持在会话级别设置时区。Flink的这些时间戳数据类型和时区支持使得跨时区处理业务数据变得容易。
数据类型
日期和时间(Date and Time)
日期(DATE
)
日期的数据类型,由年-月-日组成,取值范围为0000-01-01 ~ 9999-12-31。可以如下声明:
SQL方式:
DATE
Java方式:
DataTypes.DATE()
时间(TIME
)
无时区的时间数据类型,由hour:m
这篇关于Table API SQL之时区Time Zone详解的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!