New to the Spark environment (and fairly new to Maven) so I'm struggling with how to send the dependencies I need correctly. It looks like Spark 1.5.1 has a guava-14.0.1 dependency which it tries ...

I want to connect Kafka + Cassandra to the Spark 1.5.1. The versions of the libraries: scalaVersion := "2.10.6" libraryDependencies ++= Seq( "org.apache.spark" % "spark-streaming_2.10" % "1.5.1...

I am facing some issues with spark cassandra connector filtering for java. Cassandra allows the filtering by last column of the partition key with IN clause. e.g create table cf_text (a varchar,b...

This link shows a way to save a JavaRDD to Cassandra in this way: import static com.datastax.spark.connector.CassandraJavaUtil.*; JavaRDD<Product> productsRDD = sc.parallelize(products); jav...