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