Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- val str ="""SC Freiburg,2014,Germany,7747
- Arsenal,2014,Germany,7745
- ...
- """
- val rdd = sc.parallelize(str.split("n"))
- rdd.map (_.split(",")).keyBy(_(0)).groupByKey().map {case (k, v) => (k, v.size)}.collect
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement