@@ -0,0 +1,1005 @@
+package es.tid.cosmos.mobility.activityarea;%0A%0Aimport java.io.IOException;%0A%0Aimport com.twitter.elephantbird.mapreduce.io.ProtobufWritable;%0Aimport com.twitter.elephantbird.util.Pair;%0Aimport org.apache.hadoop.io.LongWritable;%0Aimport org.apache.hadoop.mapreduce.Mapper;%0A%0Aimport es.tid.cosmos.mobility.data.MobProtocol.Cell;%0Aimport es.tid.cosmos.mobility.data.MobProtocol.TelMonth;%0A%0A/**%0A *%0A * @author losa%0A */%0Apublic class ActivityAreaMapper extends Mapper%3C%0A        ProtobufWritable%3CTelMonth%3E, ProtobufWritable%3CCell%3E,%0A        LongWritable,%0A        Pair%3CProtobufWritable%3CTelMonth%3E, ProtobufWritable%3CCell%3E%3E%3E %7B%0A    @Override%0A    protected void map(ProtobufWritable%3CTelMonth%3E key,%0A            ProtobufWritable%3CCell%3E value, Context context)%0A            throws IOException, InterruptedException %7B%0A        key.setConverter(TelMonth.class);%0A        final TelMonth readKey = key.get();%0A        LongWritable phoneKey = new LongWritable(readKey.getPhone());%0A        context.write(phoneKey, new Pair(key, value));%0A    %7D%0A%7D%0A

Add ActivityArea Mapper to split phone from key