java - Scala classNotFound on Any 类型

Question

我正在尝试在 HashMap 中创建一个通用值类型，如下所示:

val aMap = ArrayBuffer[HashMap[String, Any]]()
aMap += HashMap()
aMap(0)("aKey") = "aStringVal"
aMap(0)("aKey2") = true        // a bool value
aMap(0)("aKey3") = 23          // an int value

这在我的 Spark-Shell 中有效，但它在 scala.Any 上给了我这个 ClassNotFoundException 在我的 IntelliJ 项目中:

org.apache.spark.streaming.scheduler.JobScheduler logError - Error running job streaming job 1521859195000 ms.0
java.lang.ClassNotFoundException: scala.Any
    at java.net.URLClassLoader.findClass(URLClassLoader.java:381)

我使用的是 Scala 2.11。有什么想法可能导致此问题吗？

Answer 1

这对我来说最终是使用 .toDF 创建一个包含混合数据的 DataFrame

我有:

val baseDataFrame = Seq(
    ("value1", "one"),
    ("value2", 2),
    ("value3", 3)
  ).toDF("column1", "column2")

此更改解决了问题:

val baseDataFrame = Seq(
    ("value1", "one"),
    ("value2", "2"),
    ("value3", "3")
  ).toDF("column1", "column2")