Reputation: 619
I am newbie to Scala. I have this code:
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)]
Above line in my code is throwing java.lang.ClassNotFoundException: scala.Any
error. I tried to make my test variable implicit also. But I still get the same error.
Also I tried changing Any
to String
in .empty[String, Any]
code. But still the same error.
Upvotes: 2
Views: 1812