Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- val visits = spark.hadoopFile("hdfs://...")
- val counts = visits.map(v => (v.url, 1)).reduceByKey((a, b) => a + b)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement