Hello
I am trying to create a SchemaRDD from a RDD of case classes. Depending on
an argument to the program these case classes should be different. But this
throws an exception. I am using Spark version 1.1.0 and Scala version 2.10.4
The exception can be reproduced by:
val table = "type 1"
impor
Hello
I am trying to create a SchemaRDD from a RDD of case classes. Depending on
an argument to the program, the program reads data of specified type and
maps it to the correct case class. But this throws an exception. I am using
Spark version 1.1.0 and Scala version 2.10.4
The exception can be
