如何扭转订购的RDD.takeOrdered（）？ [英] How to reverse ordering for RDD.takeOrdered()?

问题描述

什么是反向排序在星火的RDD的takeOrdered（）方法的语法？

What is the syntax to reverse the ordering for the takeOrdered() method of an RDD in Spark?

有关加分，什么是自定义排序的语法在星火的RDD？

For bonus points, what is the syntax for custom-ordering for an RDD in Spark?

推荐答案

逆序

val seq = Seq(3,9,2,3,5,4)
val rdd = sc.parallelize(seq,2)
rdd.takeOrdered(2)(Ordering[Int].reverse)

的结果将是阵列（9,5）的

自定义订单

我们会按年龄排序的人。

We will sort people by age.

case class Person(name:String, age:Int)
val people = Array(Person("bob", 30), Person("ann", 32), Person("carl", 19))
val rdd = sc.parallelize(people,2)
rdd.takeOrdered(1)(Ordering[Int].reverse.on(x=>x.age))

的结果将是阵（人（ANN，32））的

这篇关于如何扭转订购的RDD.takeOrdered（）？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！