我是斯卡拉的新手。我有这样的代码:
import org.apache.spark.sql.types.{StructType, DataType, AnyDataType}
..
val test = spark.sparkContext.parallelize(Tables.value.getOrElse("db.code_tbls",collection.immutable.Map.empty[String, Any]).toList.seq).toDF("code","cde_desc").as[(String, String)]
在我的代码的上面一行抛出了java.lang.ClassNotFoundException: scala.Any
错误。我也尝试使我的测试变量隐式。但我仍然收到相同的错误。
我还尝试在.empty[String, Any]
代码中将Any
更改为String
。但仍然是同样的错误。
1条答案
按热度按时间mgdq6dx11#
试着收集.immuable.Map字符串,任意