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)

文章转载自原文：