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 “”" 每个分区执行的
相关文章
相关标签/搜索