Scala实现WordCount

Question

println(List(scala.io.Source.fromFile(filePath, “UTF-8”).mkString).flatMap(x => x.split(",")).map(x => (x, 1)).groupBy(x => x._1).map(x => (x._1, x._2.size)))

Answer 1

Michael_PK 2020-04-29 00:39:19

可以的，等学了sparkrdd之后再次对比有啥差别