ReadFromDB.java

public class ReadFromDB {

	public static void main(String[] args) {

	  SparkConf sparkConf = new SparkConf().setAppName("ReadFromDB")
				.set("spark.cassandra.connection.host", "ip").setMaster("local")
		.set("spark.cassandra.auth.username", "myusername")         
		.set("spark.cassandra.auth.password", "mypass");
		
		JavaSparkContext sc = new JavaSparkContext(sparkConf);
		
		JavaRDD<String> cassandraRowsRDD = javaFunctions(sc).cassandraTable("mykeyspace", "mytable")
		        .map(new Function<CassandraRow, String>() {
		            @Override
		            public String call(CassandraRow cassandraRow) throws Exception {
		                return cassandraRow.toString();
		            }
		        });


	}


}