Flink1.7.2 local WordCount源码分析

  • 时间:
  • 浏览:1
  • 来源:神彩UU直播现场_彩神UU直播现场官方

add()调用transform,最终调用ReduceTransformation.apply,该函数会调用reduce函数,在同一次window中,每来另两个 相同key,就更新一次,实现累加,