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