Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- val a = sc.parallelize(List("dog", "salmon", "salmon", "rat", "elephant"), 3)
- val b = a.keyBy(_.length)
- val c = sc.parallelize(List("dog","cat","gnu","salmon","rabbit","turkey","wolf","bear","bee"), 1)
- val d = sc.parallelize(_.length)
- b.rightOuterJoin(d).collect
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement