Advertisement
Guest User

Untitled

a guest
Feb 16th, 2020
119
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.26 KB | None | 0 0
  1. val a = sc.parallelize(List("dog", "salmon", "salmon", "rat", "elephant"), 3)
  2. val b = a.keyBy(_.length)
  3. val c = sc.parallelize(List("dog","cat","gnu","salmon","rabbit","turkey","wolf","bear","bee"), 1)
  4. val d = sc.parallelize(_.length)
  5.  
  6. b.rightOuterJoin(d).collect
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement