Spark宽窄依赖之间的案例

1 正常spark 算子之间的转换关系 def main(args: Array[String]):Unit = {     val conf =new  SparkConf()     conf.setAppName("day03")     conf.setMaster("local")     val sc =new SparkContext(conf)     sc.setLogLevel

>>阅读原文<<