博客

import scala.io.Source

object WordCount {

  def main(args: Array[String]): Unit = {

    //获取数据源对象
    val source = Source.fromFile("D:\\yuhk\\a.txt")
    //一行行读取
    val strings: Iterator[String] = source.getLines()
    //合并为一行字符串
    val str: String = strings.mkString(",")

    val map: Map[String, Array[(String, Int)]] = str
      .split(",")
      .map((x: String) => (x, 1))
      .groupBy((t: Tuple2[String, Int]) => t._1)

    val stringToInt: Map[String, Int] = map.mapValues((arr: Array[(String, Int)]) => {
      arr.length
    })

    stringToInt.foreach(println)

  }

}