val pair = sc.textFile("/user/hive/warehouse/ages/data.txt") .flatMap(line => line.split('\n')) .map( a => a.split('|')(2).toInt -> 1 ) .reduce((x,y) => (x._1+y._1,x._2 + y._2))