class DirectBigQueryInputFormat extends InputFormat<NullWritable, GenericRecord> {

  @Override
  public RecordReader<NullWritable, GenericRecord> createRecordReader(
      InputSplit inputSplit, TaskAttemptContext context) {
    return new DirectBigQueryRecordReader();
  }

}