wordCount的认识（scala版）

val line = sc.textFile("/usr/local/word.txt");
line.flatMap(_.split(" "))
.map((_, 1)).reduceByKey(_ + _)
.collect().foreach(println)

1、通过textFile(“path/of/the/document”)

2、通过flatMap(_.split(” “))将数据按照 “ ”空格切分数据

3、通过map(( _ , 1)) 将每一条数据记录为1

4、通过reduceByKey( _ + _ ) 将数据按照key 进行数据的累加

5、collect() 执行统计操作

6、foreach(println)按照key分组dayin