Flink1.7.2 local WordCount源码分析

  • 时间:
  • 浏览:2
  • 来源:神彩排列三_彩神排列三官方

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