Mnemosyne Mnemosyne - 1 year ago 100
Scala Question

Can't Zip RDDs with unequal number of partitions. What can I use as an alternative to zip?

I have three RDDs of the same size

contains a String identifier,
contains a vector and
contains an integer value.

Essentially I want to zip those three together to get an RDD of
but I continuously get can't zip RDDs with unequal number of partitions. How can I completely bypass zip to do the abovementioned thing?

Answer Source

Try: =>x.swap).join( => x.swap)).values
Recommended from our users: Dynamic Network Monitoring from WhatsUp Gold from IPSwitch. Free Download