带有Spark Cassandra连接器的mapValues

Question

sc.cassandraTable("keyspace","table")
  .select("gender","name")
  .mapValues(v => v.get())
  .lookup("Male")

error: value mapValues is not a member of com.datastax.spark.connector.rdd.CassandraTableScanRDD[com.datastax.spark.connector.CassandraRow]

• Java 1.8.0_151
• Spark 2.2.1
• Scala 2.11
• 卡桑德拉3.11.1

Answer 1

好的。我用这个方法解决了问题，使用问题中的注释：

sc.cassandraTable[(String,String)]("keyspace","table")
  .where("gender = 'Male'")
  .select("gender","name")
  .map{case (k,v) => (v,1)}
  .reduceByKey{case (v,count) => count + count}
  .collect.foreach(println)

解决方案的关键是Spark中Cassandra行和Scala类型之间的类型转换CassandRatable[(String，String)]。

谢谢你。