def top(num : scala.Int)(implicit ord : scala.Ordering[T]) : scala.Array[T] = {**}
使用top函数的案例,并制定排序的字段(它是一个科里化函数)
代码实现:
val data = ss.sparkContext.parallelize(Array((1,1.0),(2,2.0),(3,3.0),(4,4.0)))
//--top函数用法解析,Scala Ordering对象,它会告诉Spark根据键值对里的值排序(也就是使用这个DOuble类型的数字进行排序)
val top1: Array[(Int, Double)] = data.top(1)(Ordering.by[(Int,Double),Double]{
case(id,sal)=>sal
})
print(top1.toList)