Flink应用开发系列（五十六）Table SQL开发之drop函数

本文的话，我们介绍下对应的drop函数，这里的drop函数很简单，有sql经验的同学应该都知道drop就是删除掉某个对象，例如某个数据库或者某个表。在flink table sql中drop支持的类型有：#drop多...

Raeflink系列2023-08-24974 阅读0 评论

热文Flink应用开发系列（五十五）Table SQL开发之自定义UDTF函数

在前面的文章《Flink应用开发系列（五十三）Table SQL开发之自定义UDF函数》和《Flink应用开发系列（五十四）Table SQL开发之自定义UDAF函数》我们分别介绍了一下udf和udaf函数相关的开发...

Raeflink系列2023-08-241417 阅读0 评论

热文Flink应用开发系列（五十四）Table SQL开发之自定义UDAF函数

上一篇文章《Flink应用开发系列（五十三）Table SQL开发之自定义UDF函数》我们介绍了UDF函数的开发，本文的话我们再介绍下UDAF函数的开发。在UDF里面，它是给定一个值，然后会返回一个值。但是在UDAF...

Raeflink系列2023-08-211031 阅读0 评论

热文Flink应用开发系列（五十三）Table SQL开发之自定义UDF函数

在上一篇文章《Flink应用开发系列（五十二）Table SQL开发之create function》我们介绍了创建function，在文章里面我们提过这里的函数主要是UDF，UDAF，UDTF等函数，所以本文的话，...

Raeflink系列2023-08-211211 阅读1 评论

热文Flink应用开发系列（五十二）Table SQL开发之create function

在这里function的话，其实就是我们使用的UDF,UDTF,UDAF等函数。有时候在一些特定的场景里面，我们需要在查询的时候做某些数据类的操作，但是flink这样的table sql里面没有相关的函数可用，所以这...

Raeflink系列2023-08-211009 阅读0 评论

热文Flink应用开发系列（五十一）Table SQL开发之create view

在使用传统的mysql的时候，我们知道还有一个视图的东西，也就是view，这种视图一般作为临时连接多张表或者跨库的时候使用的中间表有时候可以让我们少写一些代码，提升了查询数据的便利性。在flink table sql...

Raeflink系列2023-08-211255 阅读0 评论

Flink应用开发系列（五十）Table SQL开发之create database

前面我们介绍过在flink中，整个table sql的结构是：${catalog}.${database}.${table}。这里的database其实就是数据库，和我们日常理解的数据库是一个意思。在flink ta...

Raeflink系列2023-08-21962 阅读0 评论

热文Flink应用开发系列（四十九）Table SQL开发之create catalog

在flink中catalog就是多数据源目录的意思，整个数据库的结构是：${catalog}.${database}.${table}。除了table，其他的都是默认的default。在flink中一般在数据湖领域的...

Raeflink系列2023-08-211080 阅读0 评论

热文Flink应用开发系列（四十八）Table SQL开发之create table

在flink sql开发中，我们对于数据源来说，首先需要做的就是create table，也就是创建一张表，在flink sql中关于create table的语句和传统的mysql中创建表的是不完全一样，也就是只有...

Raeflink系列2023-08-211247 阅读0 评论

热文Flink应用开发系列（四十七）Table SQL开发之group by

在Flink的table sql里面我们还可以使用分组函数进行查询，这里的分组和sql是一样的，主要是group by函数。常用的group by函数查询语法是：select ${字段},count(*) from ...

Raeflink系列2023-08-211136 阅读0 评论

Flink应用开发系列（四十六）Table SQL开发之select distinct

在flink中我们也可以使用distinct函数来对某一列进行去重的操作，查询语法如下：select distinct id from xxxx例如：select distinct id from users1...

Raeflink系列2023-08-18908 阅读0 评论

Flink应用开发系列（四十五）Table SQL开发之select + where

在flink sql中我们查询的时候可以直接使用这种where条件的方式查询，他得查询语法和使用普通的sql进行查询方式是一样的，例如：select * from users where id = 1;同时这里的wh...

Raeflink系列2023-08-18954 阅读0 评论

热文Flink应用开发系列（四十四）Table SQL开发之create table

在flink的Table API&SQL系列中，由于我们日常使用Table API这种面向对象的方式去操作数据还是比较少，大多数情况都是使用sql的方式去操作数据。因此关于table api部分的开发部分就省略掉了，...

Raeflink系列2023-08-181039 阅读0 评论