def listagg(sc: SparkContext) {
val rd1 = sc.textFile("D:\\work\\data\\t2.txt",2)
val k2 = rd1.map { x =>
val c = x.split("\t")
(c(0), ( c(1),c(2).toInt))
val k3 = k2.sortBy(x => (x._1, x._2._2), true)  //按第一列和第三列排序  升序
val zeroValue = ""  //初始字符串
val seqOp = (u: String, v: ( String,Int)) => { u.+("|").+(v._1) }  //拼接字符串 中间加|
val compOp = (u: String, v: String) => { u.+(v) }  //拼接字符串
val vdd3 = k3.aggregateByKey(zeroValue)(seqOp, compOp)
vdd3.collect().foreach(println(_))

广播电视节目制作经营许可证(京) 字第1234号 中国互联网协会会员