sparksql實現單詞計數

一、建立SparkSessionweb val sparkSession = SparkSession.builder() .appName("SparkWordCount") .master("local[2]") .getOrCreate() 二、加載數據，使用dataset處理數據集 read來讀取能夠直接返回DataSet[String],這是個比RDD更高級的數據集 它返回一個列名

>>阅读原文<<