解决Flink案例DataStream中使用keyBy(0),keyBy弃用的问题
  TEZNKK3IfmPf 2023年11月14日 17 0

很多案例中:

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);
【版权声明】本文内容来自摩杜云社区用户原创、第三方投稿、转载,内容版权归原作者所有。本网站的目的在于传递更多信息,不拥有版权,亦不承担相应法律责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@moduyun.com

  1. 分享:
最后一次编辑于 2023年11月14日 0

暂无评论

推荐阅读
  TEZNKK3IfmPf   2023年11月12日   17   0   0 flink
  TEZNKK3IfmPf   2023年11月12日   20   0   0 flink大数据
TEZNKK3IfmPf