Flink应用开发系列(五十七)Table SQL开发之alter函数 在flink table sql中还有涉及到的alter函数,这里的alter主要是涉及到对原有的对象进行修改,目前在flink中支持的alter对象有:#修改表alter table#修改视图... Rae /flink系列 /2023-08-24 /0 评论 /403 阅读
Flink应用开发系列(五十六)Table SQL开发之drop函数 本文的话,我们介绍下对应的drop函数,这里的drop函数很简单,有sql经验的同学应该都知道drop就是删除掉某个对象,例如某个数据库或者某个表。在flink table sql中drop支持的类型有:#drop多... Rae /flink系列 /2023-08-24 /0 评论 /317 阅读
Flink应用开发系列(五十五)Table SQL开发之自定义UDTF函数 在前面的文章《Flink应用开发系列(五十三)Table SQL开发之自定义UDF函数》和《Flink应用开发系列(五十四)Table SQL开发之自定义UDAF函数》我们分别介绍了一下udf和udaf函数相关的开发... Rae /flink系列 /2023-08-24 /0 评论 /429 阅读
Flink应用开发系列(五十四)Table SQL开发之自定义UDAF函数 上一篇文章《Flink应用开发系列(五十三)Table SQL开发之自定义UDF函数》我们介绍了UDF函数的开发,本文的话我们再介绍下UDAF函数的开发。在UDF里面,它是给定一个值,然后会返回一个值。但是在UDAF... Rae /flink系列 /2023-08-21 /0 评论 /427 阅读
Flink应用开发系列(五十三)Table SQL开发之自定义UDF函数 在上一篇文章《Flink应用开发系列(五十二)Table SQL开发之create function》我们介绍了创建function,在文章里面我们提过这里的函数主要是UDF,UDAF,UDTF等函数,所以本文的话,... Rae /flink系列 /2023-08-21 /1 评论 /423 阅读
Flink应用开发系列(五十二)Table SQL开发之create function 在这里function的话,其实就是我们使用的UDF,UDTF,UDAF等函数。有时候在一些特定的场景里面,我们需要在查询的时候做某些数据类的操作,但是flink这样的table sql里面没有相关的函数可用,所以这... Rae /flink系列 /2023-08-21 /0 评论 /410 阅读
Flink应用开发系列(五十一)Table SQL开发之create view 在使用传统的mysql的时候,我们知道还有一个视图的东西,也就是view,这种视图一般作为临时连接多张表或者跨库的时候使用的中间表有时候可以让我们少写一些代码,提升了查询数据的便利性。在flink table sql... Rae /flink系列 /2023-08-21 /0 评论 /501 阅读
Flink应用开发系列(五十)Table SQL开发之create database 前面我们介绍过在flink中,整个table sql的结构是:${catalog}.${database}.${table}。这里的database其实就是数据库,和我们日常理解的数据库是一个意思。在flink ta... Rae /flink系列 /2023-08-21 /0 评论 /406 阅读
Flink应用开发系列(四十九)Table SQL开发之create catalog 在flink中catalog就是多数据源目录的意思,整个数据库的结构是:${catalog}.${database}.${table}。除了table,其他的都是默认的default。在flink中一般在数据湖领域的... Rae /flink系列 /2023-08-21 /0 评论 /502 阅读
Flink应用开发系列(四十八)Table SQL开发之create table 在flink sql开发中,我们对于数据源来说,首先需要做的就是create table,也就是创建一张表,在flink sql中关于create table的语句和传统的mysql中创建表的是不完全一样,也就是只有... Rae /flink系列 /2023-08-21 /0 评论 /631 阅读