sparksql实现单词计数

一、建立SparkSessionweb val sparkSession = SparkSession.builder() .appName("SparkWordCount") .master("local[2]") .getOrCreate() 二、加载数据，使用dataset处理数据集 read来读取能够直接返回DataSet[String],这是个比RDD更高级的数据集 它返回一个列名

>>阅读原文<<