scala – 在PairRDDFunctions.reduceByKey()中使用’case’

这是方法reduceByKey的语法

def reduceByKey(func: (V,V) ⇒ V): RDD[(K,V)]

在我练习的字数统计程序中,我看到这段代码,

val counts = words.map(word => (word,1)).reduceByKey{case (x,y) => x + y}

该应用程序使用(x,y)而不是case(x,y).这里的案例有什么用处.我也检查了@ghik here的答案.但是无法理解

解决方法

Scala支持多种定义匿名函数的方法. “case”版本被称为 Pattern Matching Anonymous Functions,它或多或少等同于：

(x: Int,y: Int) => (x,y) match { case (x,y) => x + y }

而没有案例的版本几乎是它的样子：

(x: Int,y: Int) => x + y

在这种情况下,简单_ _就足够了：

val counts = words.map(word => (word,1)).reduceByKey(_ + _)

当您使用模式匹配时,最简单的情况可能就是当您处理Scala Options时：

(x: Option[Int],y: Option[Int]) => (x,y) match {
    case (Some(xv),Some(yv)) => xv + yv
    case (Some(xv),_) => xv
    case (_,Some(yv)) => yv
    case _ => 0
}