scala – 按火花对RDD中的值排序

发布时间：2020-12-16 09:24:44 所属栏目：安全来源：网络整理

导读：我有一个火花对RDD(键,计数)如下 Array[(String,Int)] = Array((a,1),(b,2),(c,(d,3)) 使用spark scala API如何获取按值排序的新对RDD？必需结果：数组((d,3),(a,1)) 解决方法这应该工作： //Assuming the pair's second type has an Ordering,which is th

我有一个火花对RDD(键,计数)如下

Array[(String,Int)] = Array((a,1),(b,2),(c,(d,3))

使用spark scala API如何获取按值排序的新对RDD？

必需结果：数组((d,3),(a,1))

解决方法

这应该工作：

//Assuming the pair's second type has an Ordering,which is the case for Int
rdd.sortBy(_._2) // same as rdd.sortBy(pair => pair._2)

(虽然你可能也想在有关系的时候把钥匙交给账户.)

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!