public class TraitementMapper extends Mapper { @Override public void map(TypCleE cleE, TypValE valE, Context context) throws Exception { /** traitement: cleI = ..., valI = ... **/ TypCleI cleI = new TypCleI(...); TypValI valI = new TypValI(...); context.write(cleI, valI); } }