java之光 2022-08-10 21:17 采纳率: 0%
浏览 23

flink使用sum是怎么计算的

代码


object ReduceAgg {
  def main(args: Array[String]) {
    val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
    val tup: DataStream[(Int, Int)] = env.fromElements((1,2),(2,5),(2,3),(10,3),(2,8),(3,6))

    val gpT: KeyedStream[(Int, Int), Tuple] = tup.keyBy(1)
//    gpT.print()
    //gpT.print()
//    val reduce: DataStream[(Int, Int)] = gpT.reduce((before, after) => {
//      (before._1, before._2 + after._2)
//    })
    val sum: DataStream[(Int, Int)] = gpT.sum(1)
    sum.print()
    env.execute()
//    gpT.reduce((left,right)=>{
//      (left._1,right._1+right._2)
//    })
  }
}

结果


4> (1,2)
4> (2,5)
4> (2,3)
4> (2,6)
1> (2,8)
1> (3,6)

(2,3)与(2,5)不会做滚动求和吗,最不能理解的是(2,6)是怎么来的

  • 写回答

1条回答

      报告相同问题?

      相关推荐 更多相似问题

      问题事件

      • 创建了问题 8月10日

      悬赏问题

      • ¥15 使用python将分子模拟输出.gro文件
      • ¥15 港诡实录的背包系统拆解
      • ¥15 完成赛博选角的需求,随机选取所扮演的文明
      • ¥15 宽带IP网络路由器的初始路由表和最终路由表
      • ¥15 c语言基础这几个该怎么搞
      • ¥15 ip 地址转换(字符串与指针)
      • ¥15 有没有同在北京有业余时间教编程的程序员?
      • ¥15 桌面路径修改到D盘,忘记创建文件夹
      • ¥15 在网站管理的后台误操作
      • ¥16 Hdfs集群启动不成功,显示连接时间过长,而且jps中也没显示