阅读背景:

Spark算子执行流程详解之三

来源:互联网 

10.aggregate

用与聚合RDD中的元素,先使用seqOp将RDD中每个分区中的T类型元素聚合成U类型,再使用combOp将之前每个分区聚合后的U类型聚合成U类型,特别注意seqOp和combOp都会使用zeroValue的值,zeroValue的类型为U,用与聚合RDD中的元素,先使用seqOp将RDD中每个分




你的当前访问异常,请进行认证后继续阅读剩余内容。

分享到: