scala的aggregate

针对Spark的RDD，API中有一个aggregate函数，本人理解起来费了很大劲，明白以后，mark一下，供之后参考。html 首先，Spark文档中aggregate函数定义以下java def aggregate[U](zeroValue: U)(seqOp: (U, T) ⇒ U, combOp: (U, U) ⇒ U)(implicit arg0: ClassTag[U]): U Ag

>>阅读原文<<