这是方法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 }
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。