微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

大三寒假学习 spark学习 函数式编程实例

WorldCount:

  

import java.io.File
import scala.io.source
object WordCount{
    def main(args: Array[String]): Unit ={
        val dirfile = new File("F://english")
        val files = dirfile.listFiles// 获取文件列表
        for(file <- files) println(file)//遍历文件列表
        val listFiles = files.toList
        val wordsMap = scala.collection.mutable.Map[String,Int]()//单词映射,统计数目
        //对每个文件遍历
        listFiles.foreach(file => Source.fromFile(file).getLines().foreach(line => line.split(" ").
            //Scoure.fromFile(file).getLines()读取文件获取每一行
            //line => line.split(" ")分割成单词
            //对line.split(" ")集合遍历
            foreach(
                word=>{
                    if(wordsMap.contains(word)){
                        wordsMap(word)+=1
                    }else{
                        wordsMap+=(word->1)
                    }
                }//进行单词统计
            )
        ))
        println(wordsMap)
        for((key,value)<-wordsMap) println(key+": "+value)
    }
}

 

 

 

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。

相关推荐