@@ -0,0 +1,1559 @@
+/**%0A * Copyright 2017 Telefonica Investigaci%C3%B3n y Desarrollo, S.A.U%0A *%0A * This file is part of BigDataResources.%0A *%0A * BigDataResources is free software: you can redistribute it and/or modify it under the terms of the GNU Affero%0A * General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your%0A * option) any later version.%0A * BigDataResources is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the%0A * implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License%0A * for more details.%0A *%0A * You should have received a copy of the GNU Affero General Public License along with BigDataResources. If not, see%0A * http://www.gnu.org/licenses/.%0A *%0A * For those usages not covered by the GNU Affero General Public License please contact with iot_support at tid dot es%0A */%0Apackage com.telefonica.iot.bigdata.hadoop.mr.combiners;%0A%0Aimport java.io.IOException;%0Aimport org.apache.hadoop.io.Text;%0Aimport org.apache.hadoop.mapreduce.Reducer;%0Aimport org.apache.hadoop.mapreduce.Reducer.Context;%0A%0A/**%0A *%0A * @author frb%0A */%0Apublic class RecordsCombiner extends Reducer%3CText, Text, Text, Text%3E %7B%0A    %0A    private final Text commonKey = new Text(%22record%22);%0A    %0A    @Override%0A    public void reduce(Text key, Iterable%3CText%3E records, Context context) throws IOException, InterruptedException %7B%0A        for (Text record : records) %7B%0A            context.write(commonKey, record);%0A        %7D // for%0A    %7D // reduce%0A    %0A%7D // RecordsCombiner%0A

Add common combiners