Aviral Kumar Aviral Kumar - 1 year ago 93
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 ?

Answer Source

I used cogroup for this functionality.

Recommended from our users: Dynamic Network Monitoring from WhatsUp Gold from IPSwitch. Free Download