Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- Ind,Z1,10
- Jap,Z2,20
- Ind,Z1,30
- Ind,Z2,10
- Jap,Z1,20
- Ind,Z1,40
- Ind,Z2,10
- Jap,Z1,20
- val thirdRDD = baseRDD.map(x => x.split(","))
- .map(x => ((x(0), x(1)),x(2)))
- .reduceByKey(_+_)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
