Spark IMF传奇行动第17课Transformations实战总结

def main(args: Array[String]): Unit = {
    val sc = sparkContext("Transformations")

    cogroupTrans(sc)

    sc.stop() 
}
def cogroupTrans(sc:SparkContext): Unit ={
    val stuNames = Array(
      Tuple2(1,"Spark"),
      Tuple2(2,"Tecc"),
      Tuple2(3,"Hadoop")
    )
    val stuScores = Array(
      Tuple2(1,100),
      Tuple2(1,99),
      Tuple2(2,95),
      Tuple2(3,65)
    )
    val names = sc.parallelize(stuNames)
    val scores = sc.parallelize(stuScores)
    val stuNameAndScore = names.cogroup(scores)
    stuNameAndScore.collect().foreach(println)
}