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