大数据
右外连接 标签描述

1-8main defmain(args:Array[String]):Unit={ valconf=newSparkConf() .setAppName(s"${Transformation.getClass.getSimpleName}") .setMaster("local[]") valsc=newSparkContext(conf) //map(sc) //flatMap(sc) //filter(sc) //sample(sc) //union(sc) //join(sc) //gbk(sc) //rbk(sc) sc.stop() } 1.map rdd.map(func)...