scala - Spark 字数统计示例 : why error: value split is not a member of Char at the REPL?

Question

从 Spark 示例 ( https://spark.apache.org/examples.html ) 来看，代码如下所示:

    val file = spark.textFile("hdfs://...")
     val counts = file.flatMap(line => line.split(" "))
                 .map(word => (word, 1))
                 .reduceByKey(_ + _)

并在编译时工作。
但是，如果我在 Spark REPL 上尝试这个确切的代码:

scala> val lines = "abc def"
lines: String = abc def

scala> val words = lines.flatMap(_.split(" "))
<console>:12: error: **value split is not a member of Char**
       val words = lines.flatMap(_.split(" "))
                                   ^

是什么赋予了？？

谢谢
马特

Answer 1

file可能是 Iterator[String]或类似的东西。在您的代码中，lines只是一个 String .没有迭代器。这意味着当您对 String 进行平面映射时，您正在治疗 String作为集合，所以每个元素都是一个 Char .和 Char没有 split作为一种方法(没有意义)。

如果你拆开一点..

val words = lines.flatMap(x => x.split(" "))
                          ^ this is a Char

您可以在字符串本身上拆分。

val words = lines.split(" ")