You're thinking like this? => (v,None)).join( => (v,None))).map(_._2)

On Thu, Jan 23, 2014 at 6:26 PM, Evan R. Sparks <> wrote:
You could map each to an RDD[(String,None)] and do a join.

On Thu, Jan 23, 2014 at 5:18 PM, Andrew Ash <> wrote:
Hi spark users,

I recently wanted to calculate the set intersection of two RDDs of Strings.  I couldn't find a .intersection() method in the autocomplete or in the Scala API docs, so used a little set theory to end up with this:

lazy val A = ...
lazy val B = ...

Which feels very cumbersome.

Does anyone have a more idiomatic way to calculate intersection?