Spark Scala当中reduce的用法和例子

reduce将RDD中元素前两个传给输入函数,产生一个新的return值,将新产生的return值与RDD中下一个元素(即第三个元素)组成两个元素,再被传给输入函数,这样递归运作,直到最后只有一个值为止。*/ val rdd07 = sc.parallelize(1 to 10) val sum = rdd07.reduce((x, y) => x + y) println("sum is " + sum)

更多请见:https://blog.csdn.net/qq_44596980/article/details/93311547

原文链接:https://blog.csdn.net/qq_44596980/article/details/93311547

编辑于

我来说两句

0 条评论
登录 后参与评论

扫码关注云+社区

领取腾讯云代金券