Flink应用开发系列(五)DataSet开发之数据集转换函数及示例用法 在上一篇文章《Flink应用开发系列(四)DataSet开发之实现wordcount》我们介绍了wordcount的示例,在代码里面我们使用了flatmap、groupBy、sum等函数来对数据进行转换操作,本文的话... Rae /flink系列 /2023-08-02 /0 评论 /357 阅读
Flink应用开发系列(四)DataSet开发之实现wordcount 在上一篇文章《Flink应用开发系列(三)DataSet概念介绍》我们介绍了Dataset,本文的话,我们编写一个wordcount程序给大家演示一下Dataset的用法及实现效果。背景这里我们模拟从集合读取数据,然... Rae /flink系列 /2023-08-02 /0 评论 /337 阅读
Flink应用开发系列(三)DataSet概念介绍 在前面的文章里面,我们把flink基础的项目创建完成了,因此这里的话,我们开始进入实质的应用开发系列,本文的话,我们介绍下DataSet。首先说下Dataset的应用场景,这里的Dataset一般的应用场景主要是针对... Rae /flink系列 /2023-08-02 /0 评论 /414 阅读
Flink应用开发系列(二)Flink项目基本依赖 上一篇文章《Flink应用开发系列(一)创建一个java项目模板》我们创建了一个基础的模板。在pom.xml中我们可以看到默认引入了好几个依赖,示例如下:<dependency>  ... Rae /flink系列 /2023-08-02 /0 评论 /379 阅读
Flink应用开发系列(一)创建一个java项目模板 在我们安装了flink 集群及使用flink自带的案例之后,我们就会涉及到真实的flink应用的开发了,所以从本文开始,我们来挨个介绍下flink 应用开发相关的系列。本文介绍使用maven模板创建一个基于Flink... Rae /flink系列 /2023-08-02 /0 评论 /437 阅读
Flink Sql开发系列(九)Flink Sql中内置函数 在flink sql的开发中,我们还会涉及到很多的sql内置函数,可以让我们在sql开发中很方便的对数据进行处理。本文的话我们列举下Flink Sql中内置的函数,截止的Flink 版本为1.17。1)value1... Rae /flink系列 /2023-08-01 /0 评论 /722 阅读
Flink Sql开发系列(八)Flink Sql开发常用的建表语句模板 在flink sql开发中,我们必然会涉及到创建表的步骤,所以本文的话,我们介绍一些常用的建表语句模板。1)flink sql 创建kafka的表这里就是相当于with后面跟kafka,可以从kafka里面读取数据,... Rae /flink系列 /2023-08-01 /0 评论 /571 阅读
Flink Sql开发系列(七)Flink Sql开发之Insert 相关的语句 在flink sql中使用最频繁的就是Insert 相关的sql语句,当然这里的Insert 相关的sql语句也是最简单的。在flink sql开发过程中,Insert 相关的语句必须和select子查询一起用,最后... Rae /flink系列 /2023-07-31 /0 评论 /453 阅读
Flink Sql开发系列(六)Flink Sql开发之alter相关的语句 在flink sql中还会涉及到的有alter相关的语句,这里的alter的话,支持alter的类型有:alter tablealter viewalter function在日... Rae /flink系列 /2023-07-31 /0 评论 /395 阅读
Flink Sql开发系列(五)Flink Sql开发之drop相关的语句 上一篇文章《Flink Sql开发系列(四)Flink Sql开发之create相关的语句》中我们介绍了flink sql中关于create相关的语法,本文的话我们介绍下drop相关的语法,这里drop相关的语法其实... Rae /flink系列 /2023-07-31 /0 评论 /328 阅读