用scala写一段wordcount
时间: 2024-04-16 21:24:12 浏览: 100
使用Scala设计WordCount程序
以下是一个简单的使用Scala实现Word Count的程序:
```scala
import org.apache.flink.api.scala._
object WordCount {
def main(args: Array[String]): Unit = {
// 创建一个执行环境
val env = ExecutionEnvironment.getExecutionEnvironment
// 读取文本文件并将每行拆分为单词
val input = env.readTextFile("path/to/textfile")
val words = input.flatMap(line => line.split("\\s+"))
// 计算每个单词的出现次数
val counts = words.map(word => (word, 1))
.groupBy(0)
.sum(1)
// 打印结果
counts.print()
}
}
```
运行以上代码,可以读取指定路径下的文本文件,对文件中的每个单词进行计数,并输出每个单词出现的次数。
阅读全文