研发案例 大数据开发之Flink sql 的基础用法 来源: 发表时间: 2022-07-23 来源:火狐体育最新官网登录入口 作者:火狐体育app

  sql 的诞生就是为了简化我们对数据开发,可以使用少量的 sql 代码,帮助我完成对数据的查询,分析等功能

  对于用户只需要表达我想要什么,具体处理逻辑交给框架,系统处理,用户无需关心,对于一些非专业的开发人员有了解 sql,并且 sql 相对我们学习 java,c 等语言更简单,学习成本更低,如果跨团队,或者非大数据开发人员,也可以通过 sql 来进行 flink 任务的开发

  查询优化器,会对我们编写的 sql 进行优化,生成效率更好的执行计划,所以用户不需要了解底层细节,即高效的获取结果

  sql 语义发展几十年是一个很稳定的语言,少有变动,当我们引擎的升级,甚至替换成另一个引擎,都可以做到兼容地,平滑地升级,无需更改我们的已经编写好的 sql 代码

  对于 flink 通过 sql 的表达式,来完成流批的统一,一套 sql 代码,既可以跑流任务,也可以跑批任务,减少我们开发的成本

  udf : 传入一个值/多个/或者不传入,返回一个新的值,可以重载该方法,【关注尚硅谷,轻松学IT】具体会根据传入的参数调用对应eval烦恼歌发 类似`map`算子,作用于sql

  去重顾名思义,就是为了去重,去重会涉及到 retract 流(以后会详细讲)内容,会更新之前已经存在的结果

上一篇:PLM、ERP、APS、MES几种信息系统的数据集成! 下一篇:sql数据类型有哪几种
关注我们
©2022 火狐体育最新登录网址_官网app入口 京公网安备110177777720125 火狐体育最新登录网址|火狐体育app