pyspark RDD reduce、reduceByKey、reduceByKeyLocally用法

一、reduce Reduces the elements of this RDD using the specified commutative and associative binary operator. Currently reduces partitions locally. a=sc.parallelize([1,2,3,4,5],2).reduce(add) print(a) a

>>阅读原文<<