个人随笔
目录
Spark:常用转换操作:sortByKey()和sortBy()
2019-11-30 23:52:42

1.sortByKey()

功能:返回一个根据键排序的RDD

示例

  1. val list = List(("a",3),("b",2),("c",1))
  2. val pairRdd = sc.parallelize(list)
  3. pairRdd.sortByKey().collect.foreach(println)

结果

  1. (a,3)
  2. (b,2)
  3. (c,1)

如果我们想逆向排序,就在后边加上false参数。

  1. pairRdd.sortByKey(false).collect.foreach(println)

2.sortBy()

功能:返回根据提供的参数进行排序的RDD

示例  

  1. val list = List(("a",3),("b",2),("c",1))
  2. val pairRdd = sc.parallelize(list)
  3. pairRdd.sortBy(_._1).collect.foreach(println)//根据key进行排序,等同于sortByKey()

结果同上

  1. val list = List(("a",3),("b",2),("c",1))
  2. val pairRdd = sc.parallelize(list)
  3. pairRdd.sortBy(_._2).collect.foreach(println)//用value进行排序

结果

  1. (c,1)
  2. (b,2)
  3. (a,3)

如果我们想逆向排序,就在后边加上false参数。

  1. pairRdd.sortBy(_._2,false).collect.foreach(println)
 246

啊!这个可能是世界上最丑的留言输入框功能~


当然,也是最丑的留言列表

有疑问发邮件到 : suibibk@qq.com 侵权立删
Copyright : 个人随笔   备案号 : 粤ICP备18099399号-2