Advertisement
Guest User

Untitled

a guest
Jun 18th, 2019
70
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.22 KB | None | 0 0
  1. val str ="""SC Freiburg,2014,Germany,7747
  2. Arsenal,2014,Germany,7745
  3. ...
  4. """
  5. val rdd = sc.parallelize(str.split("n"))
  6. rdd.map (_.split(",")).keyBy(_(0)).groupByKey().map {case (k, v) => (k, v.size)}.collect
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement