RDD行动操作算子 --- fold（初始值）、reduce

RDD行动操作算子 --- fold（初始值）、reduce

reduce()与fold()方法是对同种元素类型数据的RDD进行聚合操作，即必须同构。其返回值返回一个同样类型的新元素。

@Test def fold(): Unit ={ val source = sc.parallelize(Seq(1,2,3,4,5,6)) val fold = source.fold(0)((x,y) => x+y) println(fold) //21 0+1+2+3+4+5+6 val reduce = source.reduce((x,y) => x+y) println(reduce) // 21 1+2+3+4+5+6 }

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。