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

>>阅读原文<<