public class TraitementCombiner extends Reducer { @Override public void reduce(TypCleI cleI, Iterable listeI, Context context) throws Exception { for (TypValI val: listeI) { /** traitement: cleS = ..., valS = ... **/ } context.write(new TypCleI(cleS), new TypValI(valS)); } }