144145146147148149150151152153154
job.setInputFormatClass(AvroKeyInputFormat.class); job.setOutputFormatClass(AvroTrevniKeyOutputFormat.class); job.waitForCompletion(true); wordCountUtil.validateCountsFile(); } public void checkInputFormat() throws Exception { Job job = new Job();