Advertisement
Guest User

Untitled

a guest
Feb 9th, 2016
63
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.27 KB | None | 0 0
  1. val lines = sc.textFile(args(0), 1)
  2.  
  3. val words = lines.flatMap(l => SPACE.split(l))
  4. val ones = words.map(w => (w,1))
  5. val counts = ones.reduceByKey(_ + _)
  6.  
  7. //val output = counts.collect()
  8. //output.foreach(t => println(t._1 + ": " + t._2))
  9. counts.saveAsTextFile(args(1))
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement