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

>>阅读原文<<