pyspark.RDD aggregate 操作詳解

aggregate(zeroValue, seqOp, combOp) Aggregate the elements of each partition, and then the results for all the partitions, using a given combine functions and a neutral 「zero value.」 seqOp 「」" 每個分區執行的

>>阅读原文<<