求助，如何使用 scala 语言中的 flatMap 语句进行数据压缩呢？

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

这是一个创建于 3115 天前的主题，其中的信息可能已经有所发展或是发生改变。

最近在学习大数据，看到一个练习题。题目如下：在 Spark-Shell 中使用 scala 语言对文件使用 flatMap 语句进行数据压缩，压缩的所有数据以空格为分隔符，压缩后对字母进行 key：Value 计数（字母为 key,出现次数为 Vlaue ）。

压缩

Scala

flatmap

语句

1 条回复 • 2017-05-22 17:48:25 +08:00

fdhdd

2017-05-22 17:48:25 +08:00

相当于 wordcount 吧
val f = scala.io.Source.fromFile("yourFile")
val wordCount = f.getLines.map(_.split(" ")).flatMap(a => a).groupBy(identity).mapValues(_.length)