try this:JavaRDD mapr = listrdd.map(x -> broadcastVar.value().get(x));
On Wednesday, December 21, 2016 2:25 PM, Sateesh Karuturi
wrote:
I need to process spark Broadcast variables using Java RDD API. This is my
code what i have tried so far:This is only sample code to check whether it
I need to process spark Broadcast variables using Java RDD API. This is my
code what i have tried so far:
This is only sample code to check whether its works or not? In my case i
need to work on two csvfiles.
SparkConf conf = new
SparkConf().setAppName("BroadcastVariable").setMaster("local");