热文Flink应用开发系列（六十五）Table SQL开发之添加依赖包

在flink环境中，我们有时候由于不能重启整个flink集群，但是由于job作业的原因需要把对应的jar包添加到flink的执行环境中去，怎么办呢？这里在flink table sql 官方里面提供了jar相关的函数...

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

热文Flink应用开发系列（六十四）Table SQL开发之set函数

在flink table sql中，我们经常会涉及到set一些东西，例如：SET execution.checkpointing.interval = 3s;示例图如下：关于set的话，我们在前面的文章介绍过，可参考...

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

热文Flink应用开发系列（六十三）Table SQL开发之load函数和unload函数

在flink table sql中我们还有一些场景，例如我们要在flink中对接hive执行相关的sql信息，此时就需要把hive的模块给引入进来，就需要使用到load函数，整个load函数的基础语法如下：LOAD ...

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

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

在flink table sql开发中还有一个我们常用的函数就是show，这里的show主要是为了查看某些信息，例如查看某个多数据源目录，某张表等等。这个show函数在传统的mysql中使用比较少，但是在大数据的场景...

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

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

在传统的mysql中，当我们涉及到sql优化的时候，我们经常使用expalin这个函数来对sql进行分析，在flink table sql中我们照样也有这个explain函数，这个explain函数也是为了方便分析s...

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

热文Flink应用开发系列（六十）Table SQL开发之describe函数

在flink table sql里面的describe语句其实和mysql的语句是一样的，就是查看某个表结构，例如：describe users; desc users;这里我们可以同时使用describe和desc...

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

热文Flink应用开发系列（五十九）Table SQL开发之analyze函数

在flink的table sql中analyze函数主要是用来做分析统计的，主要是统计表的信息，目前整个analyze函数主要应用于batch模式不能用于流模式，同时只能应用于表，不能应用于视图等。整个analyze...

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

热文Flink应用开发系列（五十八）Table SQL开发之insert函数

在flink中我们还会涉及到经常插入数据的操作，在flink中我们使用insert的场景有如下2种情况：1、使用select把数据插入到对应的表中。 2、直接insert数据到对应的表中。前置：对应使用insert函...

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

热文Flink应用开发系列（五十七）Table SQL开发之alter函数

在flink table sql中还有涉及到的alter函数，这里的alter主要是涉及到对原有的对象进行修改，目前在flink中支持的alter对象有：#修改表 alter table #修改视图 alter vi...

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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