https://github.com/apache/spark/blob/master/examples/src/main/scala/org/apache/spark/examples/SparkKMeans.scala#L82就是這里第82行 val pointStats = closest.reduceByKey{case ((p1, c1), (p2, c2)) => (p1 + p2, c1 + c2)}整個(gè)不懂啥意思，另外，為什么reduceByKey后面是大括號(hào){}
目前暫無(wú)任何回答
- 0 回答
- 0 關(guān)注
- 926 瀏覽
添加回答
舉報(bào)
0/150
提交
取消