Flink应用开发系列(六十三)Table SQL开发之load函数和unload函数 在flink table sql中我们还有一些场景,例如我们要在flink中对接hive执行相关的sql信息,此时就需要把hive的模块给引入进来,就需要使用到load函数,整个load函数的基础语法如下:LOAD&... Rae /flink系列 /2023-08-24 /0 评论 /352 阅读
Flink应用开发系列(六十二)Table SQL开发之show函数 在flink table sql开发中还有一个我们常用的函数就是show,这里的show主要是为了查看某些信息,例如查看某个多数据源目录,某张表等等。这个show函数在传统的mysql中使用比较少,但是在大数据的场景... Rae /flink系列 /2023-08-24 /0 评论 /372 阅读
Flink应用开发系列(六十一)Table SQL开发之explain函数 在传统的mysql中,当我们涉及到sql优化的时候,我们经常使用expalin这个函数来对sql进行分析,在flink table sql中我们照样也有这个explain函数,这个explain函数也是为了方便分析s... Rae /flink系列 /2023-08-24 /0 评论 /356 阅读
Flink应用开发系列(六十)Table SQL开发之describe函数 在flink table sql里面的describe语句其实和mysql的语句是一样的,就是查看某个表结构,例如:describe users;desc users;这里我们可以同时使用de... Rae /flink系列 /2023-08-24 /0 评论 /446 阅读
Flink应用开发系列(五十九)Table SQL开发之analyze函数 在flink的table sql中analyze函数主要是用来做分析统计的,主要是统计表的信息,目前整个analyze函数主要应用于batch模式不能用于流模式,同时只能应用于表,不能应用于视图等。整个analyze... Rae /flink系列 /2023-08-24 /0 评论 /483 阅读
Flink应用开发系列(五十八)Table SQL开发之insert函数 在flink中我们还会涉及到经常插入数据的操作,在flink中我们使用insert的场景有如下2种情况:1、使用select把数据插入到对应的表中。2、直接insert数据到对应的表中。前置:对应使用insert... Rae /flink系列 /2023-08-24 /0 评论 /395 阅读
Flink应用开发系列(五十七)Table SQL开发之alter函数 在flink table sql中还有涉及到的alter函数,这里的alter主要是涉及到对原有的对象进行修改,目前在flink中支持的alter对象有:#修改表alter table#修改视图... Rae /flink系列 /2023-08-24 /0 评论 /367 阅读
Flink应用开发系列(五十六)Table SQL开发之drop函数 本文的话,我们介绍下对应的drop函数,这里的drop函数很简单,有sql经验的同学应该都知道drop就是删除掉某个对象,例如某个数据库或者某个表。在flink table sql中drop支持的类型有:#drop多... Rae /flink系列 /2023-08-24 /0 评论 /302 阅读
Flink应用开发系列(五十五)Table SQL开发之自定义UDTF函数 在前面的文章《Flink应用开发系列(五十三)Table SQL开发之自定义UDF函数》和《Flink应用开发系列(五十四)Table SQL开发之自定义UDAF函数》我们分别介绍了一下udf和udaf函数相关的开发... Rae /flink系列 /2023-08-24 /0 评论 /391 阅读
Flink应用开发系列(五十四)Table SQL开发之自定义UDAF函数 上一篇文章《Flink应用开发系列(五十三)Table SQL开发之自定义UDF函数》我们介绍了UDF函数的开发,本文的话我们再介绍下UDAF函数的开发。在UDF里面,它是给定一个值,然后会返回一个值。但是在UDAF... Rae /flink系列 /2023-08-21 /0 评论 /389 阅读