image.png
val a = sc.parallelize(List("dog", "tiger", "lion", "cat", "panther", "eagle"), 2)
val b =...image.png
val c = sc.parallelize(List("cat", "dog", "tiger", "lion", "gnu", "crocodile", "ant", "whale...image.png
val a = sc.parallelize(List("dog", "tiger", "lion", "cat", "panther", "eagle"), 2)
val b =...image.png
val a = sc.parallelize(1 to 100, 3)
a.reduce(_ + _)
res41: Int = 5050
11)fold:与reduce类似,不同的是每次对分区内的...函数,第一个reduce函数对各个分区内的数据聚集,每个分区得到一个结果。