Flink Sql源表时间类型及水印字段生成

test01

2020-06-01T03:56:53.123 pt AS PROCTIME() pt
2020-06-01T11:56:50 wt AS TO_TIMESTAMP(t4) wt
2020-06-01T11:56:50 t5 AS CAST(FROM_UNIXTIME(CAST(t3 AS BIGINT)) AS TIMESTAMP) t5

源端字段级类型	源端发送数据格式	映射后的数据格式	建表语句操作(映射关系)	映射后的字段
t1[String]	Mon Jun 01 11:56:50 CST 2020	Mon Jun 01 11:56:50 CST 2020	VARCHAR	t1
t2[long]	1590983810058	1590983810058	VARCHAR	t2
t3[long]	1590983810	1590983810	VARCHAR	t3
t4[String]	2020-06-01 11:56:50	2020-06-01 11:56:50	VARCHAR	t4
		2020-06-01T03:56:53.123	pt AS PROCTIME()	pt
		2020-06-01T11:56:50	wt AS TO_TIMESTAMP(t4)	wt
		2020-06-01T11:56:50	t5 AS CAST(FROM_UNIXTIME(CAST(t3 AS BIGINT)) AS TIMESTAMP)	t5

说明:
1.源表类型最好用VARCHAR去映射,如果需要水印字段使用计算列,如wt,或者t5,除非数据本身是TIMESTAMP(3)类型的;
2.生成wt字段的t4只能是VARCHAR类型,生成t5的t3只能是10位的时间戳;

具体时间函数的使用可以参考:
https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/functions/systemFunctions.html#type-conversion-functions

Flink Sql源表时间类型及水印字段生成相关推荐

Mysql在sql中截取时间类型字段的年月日和时间-DATE_FORMAT() 函数
Mysql在sql中截取时间类型字段的年月日和时间 DATE_FORMAT() 函数用于以不同的格式显示日期/时间数据. 下面的脚本使用 DATE_FORMAT() 函数来显示不同的格式.我们使用 N ...
万字详述 Flink SQL 4 种时间窗口语义！（收藏）
DML:窗口聚合大家好我是老羊,由于窗口涉及到的知识内容比较多,所以博主先为大家说明介绍下面内容时的思路,大家跟着思路走.思路如下: ⭐ 先介绍 Flink SQL 支持的 4 种时间窗口 ⭐ 分别 ...
SQL日期与时间类型
一.日期与时间值 DATE '2001-08-22' TIMESTAMP '2001-08-22 03:04:05.321' 二.时间和字符串转换 1.时间转字符 -- 将timestamp转换化为指 ...
mysql 时间类型转化_Mysql 字段类型转化和时间类型相关处理
I) 字段类型转化 MySQL 的CAST()和CONVERT()函数可用来获取一个类型的值,并产生另一个类型的值.两者具体的语法如下: CAST(value as type); CONVERT(va ...
Sql获取表信息(包括结构及字段说明)
SELECT 表名 = case when a.colorder=1 then d.name else '' end, 表说明 = case when a.colo ...
SQL多表联合查询时采用字段模糊匹配
先说一下背景和要求: 背景:由于业务或是其他不描述的原因的问题导致原有存储的数据发生变动,与现有数据有差别,但还是能勉强看明白数据内容. 要求:实现A表的名称字段和B表的名称字段要模糊匹配. 上图: ...
Blink SQL之创建日志服务SLS源表
创建日志服务SLS源表仅适用于Blink 1.4.5及以上版本. 什么是日志服务日志服务SLS是针对日志类数据的一站式服务,对于日志服务而言,数据格式类似JSON,示例如下. {"a&q ...
flink中的事件时间和水印
引言在Flink流式引擎消费平台的项目中遇到数据处理顺序错乱的问题,导致项目处于一个不可用状态.本文记录了流式引擎中处理乱序方案中的基础知识点. 正文一事件时间(EventTime)和水印(Wa ...
【Flink】Flink 源码阅读笔记（16）- Flink SQL 的元数据管理
1.概述转载:Flink 源码阅读笔记(16)- Flink SQL 的元数据管理 Flink 源码阅读笔记(17)- Flink SQL 中的时间属

Flink Sql源表时间类型及水印字段生成

Flink Sql源表时间类型及水印字段生成相关推荐

最新文章

热门文章