TSFHiveInputFormat extends FileInputFormat<NullWritable, MapWritable> { @Override public RecordReader<NullWritable, MapWritable> getRecordReader(InputSplit split, JobConf job, Reporter reporter) throws IOException { return new TSFHiveRecordReader(split, job); }  @Override RecordReader<NullWritable, MapWritable> getRecordReader(InputSplit split, JobConf job,
      Reporter reporter); @Override InputSplit[] getSplits(JobConf job, int numSplits);  }
@Test public void testGetRecordReader() { try { RecordReader<NullWritable, MapWritable> recordReader = inputFormat.getRecordReader(inputSplit, job, null); assertTrue(recordReader instanceof TSFHiveRecordReader); } catch (IOException e) { e.printStackTrace(); fail(); } }