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