fold是aggregate的简化,如果分区内和分区间的计算规则是一样的,那么就可以使用fold val rdd: RDD[Int] = sparkContext.makeRDD(List(1, 2, 3, 4), 8)val res3: Int = rdd.fold(10)(_ + _)println(res3) //输出: 100