热文Flink应用开发系列(四十三)Table API&SQL时区 在Flink的Table API&SQLk开发的时候,我们我们了解到数据都是做成了table,然后使用sql的形式去对数据进行处理。这里我们回忆一下,使用传统的mysql的时候,我们jdbc里面是不是要传入一个时区?... Raeflink系列2023-08-181040 阅读0 评论
Flink应用开发系列(四十二)Table API&SQL支持的数据类型 在flink的table api&sql应用程序开发中,我们知道是吧所有的数据结构抽象成了一张表table,然后使用sql的语法对数据进行处理。那么既然是sql的语法,那么整个数据结构就会有一些基本的数据类型的支持,... Raeflink系列2023-08-18821 阅读0 评论
Flink中可以在同一条查询中使用不同的TableEnvironment 吗? Flink中可以在同一条查询中使用不同的TableEnvironment 吗?... 帅平面试刷题2023-08-18520 阅读1 评论
Flink应用开发系列(四十一)Table SQL案例 前一篇文章《Flink应用开发系列(四十)Table API案例》我们介绍了table api相关的案例,这里的话我们使用flink自带的datagen工具来演示下table sql的案例,下面直接上代码:packa... Raeflink系列2023-08-17929 阅读0 评论
热文Flink应用开发系列(四十)Table API案例 上文《Flink应用开发系列(三十九)Table API & SQL介绍》我们介绍了一下Flink中Table API和Sql的基本概念,本文的话,我们用代码来演示一下Table API开发的相关案例,直接来上代码:... Raeflink系列2023-08-171077 阅读0 评论
热文Flink运行报错:Could not find any factories that implement ExecutorFactory Flink版本1.17.0,运行table api的时候报错了,提示: Exception in thread "main" org.apache.flink.table.api.TableException: Co... 帅平大数据2023-08-171991 阅读1 评论
Flink运行报错:ClassNotFoundException: org.apache.flink.table.api.bridge.java.StreamTableEnvironment flink版本是1.17.0,在本地idea测试table api的时候报错,提示: Exception in thread "main" java.lang.NoClassDefFoundError: org/ap... 帅平大数据2023-08-17992 阅读1 评论
热文Flink应用开发系列(三十九)Table API & SQL介绍 在flink 应用程序中还有一个比较大的模块,也就是Table API & SQL模块,这个模块对于我们在实际的开发过程中来说,使用频率非常高,特别是配合Dinky 使用可以在实际的开发中极大的增加我们的开发效率。这... Raeflink系列2023-08-171002 阅读0 评论
热文Flink应用开发系列(三十八)DataStream开发之参数读取工具类 对于有大数据开发经验的同学,应该知道,我们经常会涉及到在运行job的时候,我们可能会从命令行手动传递参数,同时也可能使用某个外部的配置文件配置参数,然后在job任务中进行数据读取。在flink中,我们经常使用到的参数... Raeflink系列2023-08-161137 阅读0 评论