[學習筆記] reduce將RDD中元素前兩個傳給輸入函數，產生一個新的return值，將新產生的return值與RDD中下一個元素（即第三個元素）組成兩個元素，再被傳給輸入函數，這樣遞歸運作，直到最後只有一個值為止。*/ val rdd07 = sc.parallelize(1 to 10) va ...
[學習筆記]
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
