1.aggregate: 先進行局部聚合，在進行全局聚合 val z = sc.parallelize(List(1,2,3,4,5,6), 2) z.mapPartiti...
發(fā)簡信
IP屬地：北京
-
Spark RDD API -
沒有到不了的田野
1.aggregate: 先進行局部聚合，在進行全局聚合 val z = sc.parallelize(List(1,2,3,4,5,6), 2) z.mapPartiti...
