0
点赞
收藏
分享

微信扫一扫

RDD行动操作算子 --- fold(初始值)、reduce

爱我中华8898 2022-08-12 阅读 65


  • 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
}


举报

相关推荐

0 条评论