Spark代码笔记03——自定义排序、自定义分区、累加器、广播变量

一、自定义排序 自定义排序 Spark对简单的数据类型可以直接排序,但是对于一些复杂的条件就需要用自定义排序来实现了 1.第一种定义方法: 用到了隐式转换 package scalaBase.day11 import org.apache.spark.rdd.RDD import org.apache.spark.{SparkConf, SparkContext} case class Girl(name:String,faceValue:Int,age:Int) object myOrder{ implicit val girlOrdering=new Ordering[Gi