Example with the new API
Job job = new Job(); mapDriver = MapDriver.newMapDriver(mapper).withConfiguration(job.getConfiguration()); job.setInputFormatClass(AvroKeyInputFormat.class); job.setOutputFormatClass(AvroKeyOutputFormat.class); AvroJob.setInputKeySchema(job, MyAvro.SCHEMA$); AvroJob.setMapOutputKeySchema(job, MyAvro.SCHEMA$); AvroJob.setOutputKeySchema(job, MyAvro.SCHEMA$);