PySpark-aggregate函数说明

汇集各分区内的元素，并利用combOp和zerovalue函数将各分区合并 The functions  op(t1, t2)  is allowed to modify  t1  and return it as its result value to avoid object allocation; however, it should not modify  t2 . 函数 op(t1, t

>>阅读原文<<