Spark API 詳解/大白話解釋 之 reduce、reduceByKey

reduce(binary_function)  reduce將RDD中元素前兩個傳給輸入函數，產生一個新的return值，新產生的return值與RDD中下一個元素（第三個元素）組成兩個元素，再被傳給輸入函數，直到最後只有一個值爲止。函數 val c = sc.parallelize(1 to 10) c.reduce((x, y) => x + y)//結果55 1 2 1 2 具體過程，RD

>>阅读原文<<