@@ -0,0 +1,807 @@
+package es.tid.cosmos.mobility.activityarea;%0A%0Aimport java.io.IOException;%0A%0Aimport com.twitter.elephantbird.mapreduce.io.ProtobufWritable;%0Aimport org.apache.hadoop.mapreduce.Reducer;%0A%0Aimport es.tid.cosmos.mobility.data.MobProtocol.ActivityArea;%0Aimport es.tid.cosmos.mobility.data.MobProtocol.ActivityAreaKey;%0Aimport es.tid.cosmos.mobility.data.MobProtocol.Cell;%0A%0A/**%0A *%0A * @author losa%0A */%0Apublic class  FusionTotalVarsReducer extends Reducer%3C%0A        ProtobufWritable%3CActivityAreaKey%3E, ProtobufWritable%3CActivityArea%3E,%0A        ProtobufWritable%3CActivityAreaKey%3E, ProtobufWritable%3CCell%3E%3E %7B%0A    @Override%0A    protected void reduce(ProtobufWritable%3CActivityAreaKey%3E key,%0A            Iterable%3CProtobufWritable%3CActivityArea%3E%3E values, Context context)%0A            throws IOException, InterruptedException %7B%0A    %7D%0A%7D%0A

Add Reducer to fusion total vars