一、基础数据类型
1、字符串:CHAR、VARCHAR、STRING
2、二进制:BINARY、VARBINARY、BYTES
3、数值:
* DECIMAL:适用于存储例如商品价格等金融方面的数据,相比于DOUBLE它的取值范围更大一些
* NUMERIC
* TINYINT
* SMALLINT
* INT \ INTEGER:整数
* BIGINT:值很大的整数
* FLOAT:针对单精度的浮点数据
* DOUBLE:针对双精度的浮点数据
4、布尔:BOOLEAN
5、空值:NULL
6、时间日期:
* DATE:年月日
* TIME:时分秒
* TIMESTAMP:年月日时分秒
* TIMESTAMP_LTZ:年月日时分秒,带上本地时区(并不是带上时区标识,而是将时间进行转化显示出来),这个时区是FlinkSQL的配置决定的”tEnv.getConfig.setLocalTimeZone(ZoneId.of(xxx))”,如果没有配置则使用本地电脑时区
* INTERVAL:INTERVAL YEAR TO MONTH、INTERVAL DAY TO SECOND等,加减时间用的,可写在DQL语句中

二、复合数据类型
1、数组:ARRAY<T>
2、键值对:MAP<K,V>
3、集合:MULTISET<T>
4、对象:ROW<f0 t0,f1 t1,…>f为字段,t为类型

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注