@@ -0,0 +1,1435 @@
+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.Reducer;%0A%0Aimport es.tid.ps.mobility.data.MxProtocol.BtsCounter;%0Aimport es.tid.ps.mobility.data.MxProtocol.NodeMxCounter;%0A%0A/**%0A *%0A * @author dmicol%0A */%0Apublic class MobmxNodeMobInfoReducer extends Reducer%3CIntWritable,%0A        ProtobufWritable%3CBtsCounter%3E, IntWritable,%0A        ProtobufWritable%3CNodeMxCounter%3E%3E %7B%0A    @Override%0A    protected void reduce(IntWritable key,%0A            Iterable%3CProtobufWritable%3CBtsCounter%3E%3E values, Context context)%0A            throws IOException, InterruptedException %7B%0A        NodeMxCounter.Builder nodeMxCounterBuilder = NodeMxCounter.newBuilder();%0A        NodeMxCounter nodeMxCounter = nodeMxCounterBuilder.build();%0A%0A        int valueCount = 0;%0A        for (ProtobufWritable%3CBtsCounter%3E value : values) %7B%0A            valueCount++;%0A            BtsCounter btsCounter = value.get();%0A            nodeMxCounterBuilder.addBts(btsCounter);%0A            nodeMxCounterBuilder.setBtsLength(valueCount);%0A            nodeMxCounterBuilder.setBtsMaxLength(valueCount);%0A        %7D%0A%0A        ProtobufWritable%3CNodeMxCounter%3E nodeMxCounterWrapper =%0A                ProtobufWritable.newInstance(NodeMxCounter.class);%0A        nodeMxCounterWrapper.set(nodeMxCounter);%0A        context.write(key, nodeMxCounterWrapper);%0A    %7D%0A%7D%0A

Add MobmxNodeMobInfoReducer.