@@ -0,0 +1,1567 @@
+package es.tid.cosmos.mobility.clientlabelling;%0A%0Aimport java.io.IOException;%0A%0Aimport com.twitter.elephantbird.mapreduce.io.ProtobufWritable;%0Aimport org.apache.hadoop.io.LongWritable;%0Aimport org.apache.hadoop.io.NullWritable;%0Aimport org.apache.hadoop.mapreduce.Reducer;%0A%0Aimport es.tid.cosmos.mobility.data.MobProtocol.Cdr;%0Aimport es.tid.cosmos.mobility.data.MobProtocol.NodeBts;%0Aimport es.tid.cosmos.mobility.data.NodeBtsUtil;%0A%0A/**%0A *%0A * @author dmicol%0A */%0Apublic class VectorSpreadNodedayhourReducer extends Reducer%3CLongWritable,%0A        ProtobufWritable%3CCdr%3E, ProtobufWritable%3CNodeBts%3E, NullWritable%3E %7B%0A    @Override%0A    protected void reduce(LongWritable key,%0A                          Iterable%3CProtobufWritable%3CCdr%3E%3E values,%0A                          Context context) throws IOException,%0A                                                  InterruptedException %7B%0A        for (ProtobufWritable%3CCdr%3E value : values) %7B%0A            final Cdr cdr = value.get();%0A            int weekday;%0A            switch (cdr.getDate().getWeekday()) %7B%0A                case 0:%0A                    weekday = 3;%0A                    break;%0A                case 5:%0A                    weekday = 1;%0A                    break;%0A                case 6:%0A                    weekday = 2;%0A                    break;%0A                default:%0A                    weekday = 0;%0A            %7D%0A            ProtobufWritable%3CNodeBts%3E bts = NodeBtsUtil.createAndWrap(%0A                    key.get(), 0, weekday, cdr.getTime().getHour());%0A            context.write(bts, NullWritable.get());%0A        %7D%0A    %7D%0A%7D%0A

Add VectorSpreadNodedayhourReducer.