解决Flink案例DataStream中使用keyBy(0)，keyBy弃用的问题

很多案例中：

DataStream<Tuple2<String, Integer>> resultStream = inputDataStream.flatMap(new WordCount.MyFlatMapper()).keyBy(0) // 这里弃用.sum(1);

改为：

DataStream<Tuple2<String, Integer>> resultStream =inputDataStream.flatMap(new WordCount.MyFlatMapper()).keyBy(tuple -> tuple.f0) // 修改后，使用tuple.f0表示第0个位置的信息.sum(1);

解决Flink案例DataStream中使用keyBy(0)，keyBy弃用的问题相关推荐

解决Flink输出日志中时间比当前时间晚8个小时的问题
Flink安装在CentOS7上,默认时间是UTC时间,查看Flink日志,发现输出时间比当前时间晚8个小时. 通过如下命令,调整成北京时间 cp /usr/share/zoneinfo/Asia/S ...
flink的datastream中的closewith与反馈环(feed stream)的意思
官网例子 DataStream<Long> someIntegers = env.generateSequence(0, 1000);IterativeStream<Long> ...
烂泥：【解决】VMware Workstation中安装ESXI5.0双网卡问题
2019独角兽企业重金招聘Python工程师标准>>> 本文由秀依林枫提供友情赞助,首发于烂泥行天下. 由于需要做ESXI相关的实验,所以就在自己的机器上利用VM虚拟ESXI进行实验 ...
flink去重（二）解决flink、flink-sql去重过程中的热点问题
解决flink.flink-sql去重过程中的热点问题 1.flink-sql解决热点问题使用Sql去实现一个去重功能,通常会这样实现 SELECT day, COUNT(DISTINCT user ...
oracle忽略除数为0,ora-01476除数为0的解决办法，oracle中decode()的使用
执行报表查询,固定的一个时间点没有数据,应该是有数据的,把前一个时间节点往前调是有的,往后调也有 bebug报错把sql放到数据库中,发现提示如截图 ====================== 解 ...
解决springboot整合dubbo中No provider available from registry 127.0.0.1:2181 for service x.x.x on consumer
解决springboot整合dubbo中No provider available from registry 127.0.0.1:2181 for service x.x.x on consumer ...
mysql中除数为0怎么解决_ora-01476除数为0的解决办法，oracle中decode()的使用
执行报表查询,固定的一个时间点没有数据,应该是有数据的,把前一个时间节点往前调是有的,往后调也有 bebug报错把sql放到数据库中,发现提示如截图 ====================== 解 ...
记一次解决maven项目sonarqube中覆盖率一直显示为0的问题.jacoco统计显示.
用了整整三天.QAQ.靠体力一下下试出来的结果.踩了个坑. 一开始,项目的覆盖率显示的是0,单元测试数也没有显示. 首先,想到的是test中的项目包结构目录的问题. 倒不是一定是全的,需要的包的路径结 ...
flink 自定义窗口_《从0到1学习Flink》—— Flink Data transformation(转换)
前言在第一篇介绍 Flink 的文章 <<从0到1学习Flink>-- Apache Flink 介绍> 中就说过 Flink 程序的结构 Flink 应用程序结构就是如上图 ...

解决Flink案例DataStream中使用keyBy(0)，keyBy弃用的问题

解决Flink案例DataStream中使用keyBy(0)，keyBy弃用的问题相关推荐

最新文章

热门文章