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

>>阅读原文<<