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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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