SparkRDD-top函数-指定排序字段

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)