Skip to content

Instantly share code, notes, and snippets.

View 2eljd2's full-sized avatar

Dineshkumar Panneerselvam 2eljd2

View GitHub Profile
@2eljd2
2eljd2 / JavaDemo.java
Created April 25, 2018 19:14 — forked from jacek-lewandowski/JavaDemo.java
Java API for Spark Cassandra Connector - tutorial for blog post
package com.datastax.spark.demo;
import com.datastax.driver.core.Session;
import com.datastax.spark.connector.cql.CassandraConnector;
import com.google.common.base.Optional;
import org.apache.spark.SparkConf;
import org.apache.spark.api.java.JavaPairRDD;
import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.api.java.function.FlatMapFunction;