291c38d72785

1.aggregate: 先进行局部聚合，在进行全局聚合 val z = sc.parallelize(List(1,2,3,4,5,6), 2) z.mapPartiti...