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

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

>>阅读原文<<