键值对rdd求value最大值

xiaobaiyang 发表于 2017-5-17 09:03
scala> val result = rdd.reduce((x,y) => (if(x._2 < y._2) y else x))
result: (String, Int) = (Andy ...

对，我怎么就没想到。

w517424787 发表于 2017-5-17 11:40
scala> rdd.map(x=>(x._2,x)).sortByKey(false).map(x=>x._2).take(1)
res6: Array[(String, Int)] = Arra ...

长知识了，谢谢

太好了，过来看看