Re: Deserialize Map[Int, UDT] to a case class from Spark Connector

2018-03-25 Thread Christophe Schmitz
Hi Guillermo Which version of Spark are you using? Starting with Version 2.0, Spark is built with Scala 2.11 by default. If you are using a prior version (which looks like it's the case since your error message mention scala 2.10), you might need to build it yourself from sources with Scala 2.11 s

Deserialize Map[Int, UDT] to a case class from Spark Connector

2018-03-25 Thread Guillermo Ortiz
Hello, I'm working with UDT's and spark connector with these dependencies: 2.11.12 2.0.2 2.0.7 3.4.0 org.apache.spark spark-core_2.11 ${spark.version} org.apache.spark spark-streaming_2.11 ${spark.version} com.datastax.spark spark-cassandra-connector_2.11 ${cassandra-conector.version}