热文Flink应用开发系列(五十二)Table SQL开发之create function 在这里function的话,其实就是我们使用的UDF,UDTF,UDAF等函数。有时候在一些特定的场景里面,我们需要在查询的时候做某些数据类的操作,但是flink这样的table sql里面没有相关的函数可用,所以这... Raeflink系列2023-08-211019 阅读0 评论
热文Flink应用开发系列(五十一)Table SQL开发之create view 在使用传统的mysql的时候,我们知道还有一个视图的东西,也就是view,这种视图一般作为临时连接多张表或者跨库的时候使用的中间表有时候可以让我们少写一些代码,提升了查询数据的便利性。在flink table sql... Raeflink系列2023-08-211274 阅读0 评论
Flink应用开发系列(五十)Table SQL开发之create database 前面我们介绍过在flink中,整个table sql的结构是:${catalog}.${database}.${table}。这里的database其实就是数据库,和我们日常理解的数据库是一个意思。在flink ta... Raeflink系列2023-08-21969 阅读0 评论
热文Flink应用开发系列(四十九)Table SQL开发之create catalog 在flink中catalog就是多数据源目录的意思,整个数据库的结构是:${catalog}.${database}.${table}。除了table,其他的都是默认的default。在flink中一般在数据湖领域的... Raeflink系列2023-08-211088 阅读0 评论
热文Flink应用开发系列(四十八)Table SQL开发之create table 在flink sql开发中,我们对于数据源来说,首先需要做的就是create table,也就是创建一张表,在flink sql中关于create table的语句和传统的mysql中创建表的是不完全一样,也就是只有... Raeflink系列2023-08-211259 阅读0 评论
热文Flink应用开发系列(四十七)Table SQL开发之group by 在Flink的table sql里面我们还可以使用分组函数进行查询,这里的分组和sql是一样的,主要是group by函数。常用的group by函数查询语法是:select ${字段},count(*) from ... Raeflink系列2023-08-211147 阅读0 评论
Flink应用开发系列(四十六)Table SQL开发之select distinct 在flink中我们也可以使用distinct函数来对某一列进行去重的操作,查询语法如下:select distinct id from xxxx例如:select distinct id from users1... Raeflink系列2023-08-18917 阅读0 评论
Flink应用开发系列(四十五)Table SQL开发之select + where 在flink sql中我们查询的时候可以直接使用这种where条件的方式查询,他得查询语法和使用普通的sql进行查询方式是一样的,例如:select * from users where id = 1;同时这里的wh... Raeflink系列2023-08-18957 阅读0 评论
热文Flink应用开发系列(四十四)Table SQL开发之create table 在flink的Table API&SQL系列中,由于我们日常使用Table API这种面向对象的方式去操作数据还是比较少,大多数情况都是使用sql的方式去操作数据。因此关于table api部分的开发部分就省略掉了,... Raeflink系列2023-08-181049 阅读0 评论
Flink应用开发系列(四十三)Table API&SQL时区 在Flink的Table API&SQLk开发的时候,我们我们了解到数据都是做成了table,然后使用sql的形式去对数据进行处理。这里我们回忆一下,使用传统的mysql的时候,我们jdbc里面是不是要传入一个时区?... Raeflink系列2023-08-18940 阅读0 评论
Flink应用开发系列(四十二)Table API&SQL支持的数据类型 在flink的table api&sql应用程序开发中,我们知道是吧所有的数据结构抽象成了一张表table,然后使用sql的语法对数据进行处理。那么既然是sql的语法,那么整个数据结构就会有一些基本的数据类型的支持,... Raeflink系列2023-08-18756 阅读0 评论
Flink应用开发系列(四十一)Table SQL案例 前一篇文章《Flink应用开发系列(四十)Table API案例》我们介绍了table api相关的案例,这里的话我们使用flink自带的datagen工具来演示下table sql的案例,下面直接上代码:packa... Raeflink系列2023-08-17866 阅读0 评论
热文Flink应用开发系列(四十)Table API案例 上文《Flink应用开发系列(三十九)Table API & SQL介绍》我们介绍了一下Flink中Table API和Sql的基本概念,本文的话,我们用代码来演示一下Table API开发的相关案例,直接来上代码:... Raeflink系列2023-08-171015 阅读0 评论
Flink应用开发系列(三十九)Table API & SQL介绍 在flink 应用程序中还有一个比较大的模块,也就是Table API & SQL模块,这个模块对于我们在实际的开发过程中来说,使用频率非常高,特别是配合Dinky 使用可以在实际的开发中极大的增加我们的开发效率。这... Raeflink系列2023-08-17932 阅读0 评论