DirectBigQueryInputFormat extends InputFormat<NullWritable, GenericRecord> { @Override public RecordReader<NullWritable, GenericRecord> createRecordReader( InputSplit inputSplit, TaskAttemptContext context) { return new DirectBigQueryRecordReader(); }  @Override List<InputSplit> getSplits(JobContext context); @Override RecordReader<NullWritable, GenericRecord> createRecordReader(
      InputSplit inputSplit, TaskAttemptContext context);  }
@Test public void createRecordReader() { assertThat( input.createRecordReader(new DirectBigQueryInputSplit("foo", "schema", 7), taskContext)) .isInstanceOf(DirectBigQueryRecordReader.class); }