关于 TableApi 的文章

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

在flink table sql中我们操作的是table表的数据，所以在日常的场景中也会涉及到delete删除数据语句，这里比较简单，和传统的mysql是一样的，示例语句如下：DELETE FROM Orders W...

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

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

在flink table sql中我们操作的是table表的数据，所以在日常的场景中也会涉及到update更新语句，这里比较简单，和传统的mysql是一样的，示例语句如下：UPDATE Orders SET `amo...

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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