Scala中的groupBy与Spark中groupByKey、ReduceByKey用法案例WordCount

1.groupBy指明以某个元素分组函数 val source = Source.fromFile("E://data.txt","UTF-8") val lines = source.getLines() val list = lines.toList.flatMap(line => line.split(" ").map(word => (word,1))) val res0 = list.g

>>阅读原文<<