Spark-reduce和reduceByKey

1.reduce函数 reduce(binary_function) reduce将RDD中元素前两个传给输入函数,产生一个新的return值,新产生的return值与RDD中下一个元素(第三个元素)组成两个元素,再被传给输入函数,直到最后只有一个值为止。code val c = sc.parallelize(1 to 5) c.reduce((x, y) => x + y) 结果为:15 流程
相关文章
相关标签/搜索