Spark cassandra 连接器的编译错误

Question

我尝试使用 CassandraConnector 将 Row 映射到 scala bean 上，如下所示：

object AttachBookingToEventSparkJob {
   def main(args: Array[String]): Unit = {
      val conf = new SparkConf(true).setAppName(appName)
      val sc = new SparkContext(conf)
      val jobParameterTable = sc.cassandraTable[SparkJobMapper](keyspace, JOB_TABLE_NAME)

   }

   case class SparkJobMapper(val col1: String, val col2:String)

 }

有效。

但如果我尝试将类 SparkJobMapper 外部化（在同一个包中），我收到以下错误：

 error: No RowReaderFactory can be found for this type
 [INFO]     val jobParameterTable = sc.cassandraTable[SparkJobMapper]
 (keyspace, JOB_TABLE_NAME)

有什么想法？

Answer 1

好吧，这是一个愚蠢的错误。忘记在我的类声明中添加 case 关键字。