Hi, I am beginner to spark , I want save the word and its count to cassandra keyspace, I wrote the following code
import org.apache.spark.SparkContext import org.apache.spark.SparkContext._ import org.apache.spark.SparkConf import com.datastax.spark.connector._ object SparkWordCount { def main(args: Array[String]) { val sc = new SparkContext(new SparkConf().setAppName("Spark Count")) val tokenized = sc.textFile(args(0)).flatMap(_.split(" ")) val wordCounts = tokenized.map((_, 1)).reduceByKey(_ + _) wordCounts.saveToCassandra("sparkdata", "words", SomeColumns("word", "count")); } and did spark-submit. The code doesn't work ( may be some very basic error because I am new to it).I know there is datastax cassandra connector but how to make connection? What all things I am missing in my code? Thanks "DISCLAIMER: This message is proprietary to Aricent and is intended solely for the use of the individual to whom it is addressed. It may contain privileged or confidential information and should not be circulated or used for any purpose other than for what it is intended. If you have received this message in error, please notify the originator immediately. If you are not the intended recipient, you are notified that you are strictly prohibited from using, copying, altering, or disclosing the contents of this message. Aricent accepts no responsibility for loss or damage arising from the use of the information transmitted by this email including damage from virus."