@@ -0,0 +1,792 @@
+package es.tid.ps.mobility.jobs;%0A%0Aimport com.twitter.elephantbird.mapreduce.io.ProtobufWritable;%0Aimport java.io.IOException;%0Aimport org.apache.hadoop.io.IntWritable;%0Aimport org.apache.hadoop.mapreduce.Mapper;%0A%0Aimport es.tid.ps.mobility.data.MxProtocol.MxCdr;%0A%0A/**%0A *%0A * @author dmicol%0A */%0Apublic class MobmxFilterCellnoinfoMapper extends Mapper%3CIntWritable,%0A        ProtobufWritable%3CMxCdr%3E, IntWritable, ProtobufWritable%3CMxCdr%3E%3E %7B%0A    @Override%0A    public void map(IntWritable key, ProtobufWritable%3CMxCdr%3E value,%0A            Context context) throws IOException, InterruptedException %7B%0A        MxCdr cdr = value.get();%0A        if (cdr.getCell() != 0) %7B%0A            context.write(new IntWritable(cdr.getCell()), value);%0A        %7D else %7B%0A            context.write(key, value);%0A        %7D%0A    %7D%0A%7D%0A

Add MobmxFilterCellnoinfoMapper.