Skip to content

Instantly share code, notes, and snippets.

@nivdul

nivdul/gist:b5a3654488886cd36dc5

Created April 19, 2015 14:56
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save nivdul/b5a3654488886cd36dc5 to your computer and use it in GitHub Desktop.
Save nivdul/b5a3654488886cd36dc5 to your computer and use it in GitHub Desktop.
Download ZIP
Spark-Cassandra connection
Raw
gistfile1.java
// define Spark context
SparkConf sparkConf = new SparkConf()
.setAppName("User's physical activity recognition")
.set("spark.cassandra.connection.host", "127.0.0.1")
.setMaster("local[*]");
JavaSparkContext sc = new JavaSparkContext(sparkConf);
// retrieve data from Cassandra and create an CassandraRDD
CassandraJavaRDD<CassandraRow> cassandraRowsRDD = javaFunctions(sc).cassandraTable("actitracker", "users");
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment