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

>>阅读原文<<