Hey All, I am unable to access objects declared and initialized outside the call() method of JavaRDD.
In the below code snippet, call() method makes a fetch call to C* but since javaSparkContext is defined outside the call method scope so compiler give a compilation error. stringRdd.foreach(new VoidFunction<String>() { @Override public void call(String str) throws Exception { JavaRDD<String> vals = javaFunctions(javaSparkContext).cassandraTable("schema", "table", String.class) .select("val"); } }); In other languages I have used closure to do this but not able to achieve the same here. Can someone suggest how to achieve this in the current code context? --Unilocal