语法问题

这个地方的t1 和 t2 分别指什么呢？

源自：Flink快速上手篇 2-1 Flink Streaming程序开发-Scala

收起

1回答

徐老师回答被采纳获得+3积分 2021-02-19 17:30:56

reduce是一个聚合函数，是针对第一个(前一个)元素和第二个(下一个)元素进行聚合计算的

所以这里的t1表示第一个元素，t2表示第二个元素

GBOYLY 提问者 #1

嗯这个我清楚我是不清楚具体指的是，就比如说hello you hello me 在此处 t1 和 t2 是指的？

2021-02-19 17:35:01
徐老师回复提问者 GBOYLY #2
这里的t1和t2对应的数据结构是这样的
(hello,1)
(hello,1)
相同key的数据会进到reduce中进行聚合

还有一个最直接的方式是，你可以在reduce函数内部添加print方法，将t1和t2的临时结果打印出来
```
.reduce((t1,t2)=>{
  println("t1---"+t1)
  println("t2---"+t2)
  (t1._1,t1._2+t2._2)
})
```
2021-02-19 17:43:47