Aviral Kumar Aviral Kumar - 4 months ago 49
Java Question

Store the value objects after joining two PairRDDs in spark

I have two PairRDDs in spark , for eg

(K1,V1) and (K1,V2)

I am trying to join these two RDDs and get the resultant joined RDD as :


How can we do this ?


I used cogroup for this functionality.