Hello,
Trying to write data from Spark to Cassandra.
Reading data from Cassandra is ok, but writing seems to give a strange
error.
Exception in thread "main" scala.ScalaReflectionException: <none> is not a
term
at scala.reflect.api.Symbols$SymbolApi$class.asTerm(Symbols.scala:259)
The scala-code :
import com.datastax.spark.connector._ import org.apache.spark.{SparkConf,
SparkContext} object ReadCassandra { def main(args: Array[String]): Unit
= { val conf = new SparkConf() .setAppName("Streaming Test")
.set("spark.executor.memory", "1g")
.set("spark.cassandra.connection.host", “XXX.XXX.XXX)
.set("spark.cassandra.auth.username","cassandra")
.set("spark.cassandra.auth.password","cassandra")
.set("spark.cassandra.connection.rpc.port","9160")
.set("spark.cassandra.connection.native.port","9042") val sc = new
SparkContext(conf) // Add record to Cassandra val
rdd_cassandra_add_row = sc.parallelize(Seq(2000,89,”test)”))
rdd_cassandra_add_row.saveToCassandra("tutorial","user",
SomeColumns("user_id","age","name")) // read the data val
rdd_cassandra = sc.cassandraTable("tutorial","user")
rdd_cassandra.toLocalIterator foreach println } }
The table description in cassandra :
user :
user_id (int)
age (int)
name (text)
Many thanks for your reply !
