Spark IMF传奇行动第19课：spark排序总结

/**
 * Created by 王家林 on 2016/1/10.
 */
object SecondarySortApp {
  def main(args: Array[String]){
    val conf = new SparkConf()  //创建SparkConf对象
    conf.setAppName("SecondarySortApp")    //设置应用程序名称，程序运行的监控界面可以看到名称
    conf.setMaster("local")    //此时，程序在本地运行，不需要安装Spark集群

    val sc = new SparkContext(conf)  //通过传入SparkConf实例来定制Spark运行具体参数和配置信息来创建SparkContext对象

    val lines = sc.textFile("src/Scdfile")   //读取一个本地文件

    val pairWithKey = lines.map(line => (
      new SecondarySortKey(line.split(" ")(0).toInt,line.split(" ")(1).toInt) , line
    ))

    val sorted = pairWithKey.sortByKey(false)

    val sortedResult = sorted.map(line => line._2)

    sortedResult.collect.foreach(println)

    sc.stop()

  }

class SecondarySortKey(val first:Int,val second:Int) extends Ordered[SecondarySortKey] with Serializable{
  def compare(other:SecondarySortKey):Int ={
    if(this.first - other.first !=0){
      this.first - other.first
    }else{
      this.second - other.second
    }
  }
}