FLINK1.12的Hbase的DATE,TIME,TIMESTAMP类型学习

发布时间:2022-07-05 发布网站:脚本宝典
脚本宝典收集整理的这篇文章主要介绍了FLINK1.12的Hbase的DATE,TIME,TIMESTAMP类型学习脚本宝典觉得挺不错的,现在分享给大家,也给大家做个参考。
类型 解释
DATE 从 1970-01-01 00:00:00 UTC 开始的天数,int 值。
TIME 从 1970-01-01 00:00:00 UTC 开始天的毫秒数,int 值。
TIMESTamP 从 1970-01-01 00:00:00 UTC 开始的毫秒数,long 值。

1.1 DATE

从上述可以看出类型DATE的底层存储为Int值,且该Int值表示从 1970-01-01 00:00:00 UTC 开始的天数。

1.1.2 当日期定义为INT时

CREATE TABLE ODS_test_LEW ( rowkey STRING ,f ROW<`c1` DOubLE,`c2` DOUBLE, `c3` INT, `c4` INT>,Primary KEY (rowkey) NOT ENFORCED )WITH( 'connector'  = 'hbase-1.4', 'table-name'  = 'ODS_TEST_LEW', 'null-string-literal'  = '', 'zookeePEr.quorum'  = 'xxx:2181');

查询

select rowkey,c4 From ODS_TEST_LEW;

显示

rowkey c4
1002 18874
111 18895
112 18855
113 18875

1.1.3 当日期定义为DATE时

CREATE TABLE ODS_TEST_LEW ( rowkey STRING ,f ROW<`c1` DOUBLE,`c2` DOUBLE, `c3` INT, `c4` DATE>,PRIMARY KEY (rowkey) NOT ENFORCED )WITH( 'connector'  = 'hbase-1.4', 'table-name'  = 'ODS_TEST_LEW', 'null-string-literal'  = '', 'zookeeper.quorum'  = 'dwrj5124:2181,dwrj5125:2181,dwrj5126:2181');

查询

select rowkey,c4 from ODS_TEST_LEW;

显示

rowkey c4
1002 2021-09-04
111 2021-09-25
112 2021-08-16
113 2021-09-05

需要注意的是当Create Table语句中定义为INT或者DATE时,要按其定义的类型插入数据,即定义为INT时,插入中该字段也要是INT,当定义为DATE时,插入中该字段也要是DATE(例如cast('2021-09-01' as DATE)转成DATE)

1.2 TIME,TIMESTAMP与DATE类似

脚本宝典总结

以上是脚本宝典为你收集整理的FLINK1.12的Hbase的DATE,TIME,TIMESTAMP类型学习全部内容,希望文章能够帮你解决FLINK1.12的Hbase的DATE,TIME,TIMESTAMP类型学习所遇到的问题。

如果觉得脚本宝典网站内容还不错,欢迎将脚本宝典推荐好友。

本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。