Flink sql 是什么 ?
sql 的诞生就是为了简化我们对数据开发,可以使用少量的 sql 代码,帮助我完成对数据的查询,分析等功能
?声明式 & 易于理解
对于用户只需要表达我想要什么,具体处理逻辑交给框架,系统处理,用户无需关心,对于一些非专业的开发人员有了解 sql,并且 sql 相对我们学习 java,c 等语言更简单,学习成本更低,如果跨团队,或者非大数据开发人员,也可以通过 sql 来进行 flink 任务的开发
自动调优
查询优化器,会对我们编写的 sql 进行优化,生成效率更好的执行计划,所以用户不需要了解底层细节,即高效的获取结果
稳定
sql 语义发展几十年是一个很稳定的语言,少有变动,当我们引擎的升级,甚至替换成另一个引擎,都可以做到兼容地,平滑地升级,无需更改我们的已经编写好的 sql 代码
流批统一的基础
对于 flink 通过 sql 的表达式,来完成流批的统一,一套 sql 代码,既可以跑流任务,也可以跑批任务,减少我们开发的成本
Flink sql 使用数据类型
--字符串类型 #char类型 CHAR CHAR(n)--n在1和2147483647之间未设置n=1 #字符串类型 VARCHAR VARCHAR(n)--n在1和2147483647之间未设置n=1 STRING--等于最大的varchar(max) #二进制类型 BINARY BINARY(n)--范围同上 #可变长度二进制类型 VARBINARY VARBINARY(n)--类似于string BYTES --数字类型 #带有精度的十进制数字类型--类似于java中的 DECIMAL DECIMAL(p) DECIMAL(p,s) DEC DEC(p) DEC(p,s) NUMERIC NUMERIC(p) NUMERIC(p,s) #带符号 TINYINT---
 1.本站遵循行业规范，任何转载的稿件都会明确标注作者和来源；2.本站的原创文章，会注明原创字样,如未注明都非原创，如有侵权请联系删除！；3.作者投稿可能会经我们编辑修改或补充；4.本站不提供任何储存功能只提供收集或者投稿人的网盘链接。 |
