reduce : 规约RDD

使用reduce成员函数对RDD进行规约操作，必须指定一个函数指定规约行为。

语法

def reduce(f: (T, T) => T): T

参数 f : 规约函数 , 两个参数分别代表RDD中的两个记录，返回值被RDD用来进行递归计算。

示例

下面的示例使用匿名函数，将所有的记录连接起来构成一个字符串：

scala> textFile.reduce((a,b)=>a+b)
res60:String = #Apache SparkSpake is a fast...

使用RDD的reduce方法进行聚合！