scala - 在 Spark RDD 中寻找最大值

Question

从以下内容中，如何获得具有最高值的元组？

Array[(String, Int)] = Array((a,30),(b,50),(c,20))

在这个例子中，我想要的结果是 (b,50)

Answer 1

您可以使用 reduce() :

val max_tuple = rdd.reduce((acc,value) => { 
  if(acc._2 < value._2) value else acc})
//max_tuple: (String, Int) = (b,50)

数据

val rdd = sc.parallelize(Array(("a",30),("b",50),("c",20)))