Advertisement
Guest User

Untitled

a guest
May 18th, 2019
109
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Scala 0.11 KB | None | 0 0
  1. val visits = spark.hadoopFile("hdfs://...")
  2. val counts = visits.map(v => (v.url, 1)).reduceByKey((a, b) => a + b)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement