Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- val com = mapped.combineByKey(
- (v : String) => (v,1),
- (acc : (String,Int),v) => (acc._1+v,acc._2+1),
- (acc1 : (String,Int), acc2 : (String,Int)) => (acc1._1+acc2._1)
- )
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement