从以下内容中，如何获得具有最高值的元组？
Array[(String, Int)] = Array((a,30),(b,50),(c,20))
在这个例子中，我想要的结果是
(b,50)
最佳答案
您可以使用 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)))
关于scala - 在 Spark RDD 中寻找最大值，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/44045530/