test_class.declarator: bqHelper
test_class.modifier: @Mock private
test_class.original_string: @Mock private BigQueryHelper bqHelper;
test_class.type: BigQueryHelper
test_class.var_name: bqHelper
test_class.declarator: bqClient
test_class.modifier: @Mock private
test_class.original_string: @Mock private BigQueryStorageClient bqClient;
test_class.type: BigQueryStorageClient
test_class.var_name: bqClient
test_class.declarator: taskContext
test_class.modifier: @Mock private
test_class.original_string: @Mock private TaskAttemptContext taskContext;
test_class.type: TaskAttemptContext
test_class.var_name: taskContext
test_class.declarator: config
test_class.modifier: private
test_class.original_string: private JobConf config;
test_class.type: JobConf
test_class.var_name: config
test_class.declarator: input
test_class.modifier: private
test_class.original_string: private DirectBigQueryInputFormat input;
test_class.type: DirectBigQueryInputFormat
test_class.var_name: input
test_class.declarator: tableRef
test_class.modifier: private
test_class.original_string: private TableReference tableRef;
test_class.type: TableReference
test_class.var_name: tableRef
test_class.declarator: jobProjectId = "foo-project"
test_class.modifier: private
test_class.original_string: private String jobProjectId = "foo-project";
test_class.type: String
test_class.var_name: jobProjectId
test_class.declarator: dataProjectId = "publicdata"
test_class.modifier: private
test_class.original_string: private String dataProjectId = "publicdata";
test_class.type: String
test_class.var_name: dataProjectId
test_class.declarator: datasetId = "test_dataset"
test_class.modifier: private
test_class.original_string: private String datasetId = "test_dataset";
test_class.type: String
test_class.var_name: datasetId
test_class.declarator: tableId = "test_table"
test_class.modifier: private
test_class.original_string: private String tableId = "test_table";
test_class.type: String
test_class.var_name: tableId
test_class.file: bigquery/src/test/java/com/google/cloud/hadoop/io/bigquery/DirectBigQueryInputFormatTest.java
test_class.identifier: DirectBigQueryInputFormatTest
test_case.body: @Test
    public void createRecordReader() {
      assertThat(
              input.createRecordReader(new DirectBigQueryInputSplit("foo", "schema", 7), taskContext))
          .isInstanceOf(DirectBigQueryRecordReader.class);
    }
test_case.class_method_signature: DirectBigQueryInputFormatTest.createRecordReader()
test_case.full_signature: @Test public void createRecordReader()
test_case.identifier: createRecordReader
test_case.invocations: isInstanceOf assertThat createRecordReader
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void createRecordReader()
focal_class.declarator: DIRECT_PARALLELISM =
        new HadoopConfigurationProperty<>(MRJobConfig.NUM_MAPS, 10)
focal_class.modifier: private static final
focal_class.original_string: private static final HadoopConfigurationProperty<Integer> DIRECT_PARALLELISM =
        new HadoopConfigurationProperty<>(MRJobConfig.NUM_MAPS, 10);
focal_class.type: HadoopConfigurationProperty<Integer>
focal_class.var_name: DIRECT_PARALLELISM
focal_class.file: bigquery/src/main/java/com/google/cloud/hadoop/io/bigquery/DirectBigQueryInputFormat.java
focal_class.identifier: DirectBigQueryInputFormat
focal_class.class_method_signature: DirectBigQueryInputFormat.getSplits(JobContext context)
focal_class.full_signature: @Override public List<InputSplit> getSplits(JobContext context)
focal_class.identifier: getSplits
focal_class.modifiers: @Override public
focal_class.parameters: (JobContext context)
focal_class.return: List<InputSplit>
focal_class.signature: List<InputSplit> getSplits(JobContext context)
focal_class.class_method_signature: DirectBigQueryInputFormat.getTable(Configuration configuration, BigQueryHelper bigQueryHelper)
focal_class.full_signature: private static Table getTable(Configuration configuration, BigQueryHelper bigQueryHelper)
focal_class.identifier: getTable
focal_class.modifiers: private static
focal_class.parameters: (Configuration configuration, BigQueryHelper bigQueryHelper)
focal_class.return: Table
focal_class.signature: Table getTable(Configuration configuration, BigQueryHelper bigQueryHelper)
focal_class.class_method_signature: DirectBigQueryInputFormat.startSession(
        Configuration configuration, Table table, BigQueryStorageClient client)
focal_class.full_signature: private static ReadSession startSession(
        Configuration configuration, Table table, BigQueryStorageClient client)
focal_class.identifier: startSession
focal_class.modifiers: private static
focal_class.parameters: (
        Configuration configuration, Table table, BigQueryStorageClient client)
focal_class.return: ReadSession
focal_class.signature: ReadSession startSession(
        Configuration configuration, Table table, BigQueryStorageClient client)
focal_class.class_method_signature: DirectBigQueryInputFormat.createRecordReader(
        InputSplit inputSplit, TaskAttemptContext context)
focal_class.full_signature: @Override public RecordReader<NullWritable, GenericRecord> createRecordReader(
        InputSplit inputSplit, TaskAttemptContext context)
focal_class.identifier: createRecordReader
focal_class.modifiers: @Override public
focal_class.parameters: (
        InputSplit inputSplit, TaskAttemptContext context)
focal_class.return: RecordReader<NullWritable, GenericRecord>
focal_class.signature: RecordReader<NullWritable, GenericRecord> createRecordReader(
        InputSplit inputSplit, TaskAttemptContext context)
focal_class.class_method_signature: DirectBigQueryInputFormat.getClient(Configuration config)
focal_class.full_signature: protected BigQueryStorageClient getClient(Configuration config)
focal_class.identifier: getClient
focal_class.modifiers: protected
focal_class.parameters: (Configuration config)
focal_class.return: BigQueryStorageClient
focal_class.signature: BigQueryStorageClient getClient(Configuration config)
focal_class.class_method_signature: DirectBigQueryInputFormat.getBigQueryHelper(Configuration config)
focal_class.full_signature: protected BigQueryHelper getBigQueryHelper(Configuration config)
focal_class.identifier: getBigQueryHelper
focal_class.modifiers: protected
focal_class.parameters: (Configuration config)
focal_class.return: BigQueryHelper
focal_class.signature: BigQueryHelper getBigQueryHelper(Configuration config)
focal_class.superclass: extends InputFormat<NullWritable, GenericRecord>
focal_method.body: @Override
    public RecordReader<NullWritable, GenericRecord> createRecordReader(
        InputSplit inputSplit, TaskAttemptContext context) {
      return new DirectBigQueryRecordReader();
    }
focal_method.class_method_signature: DirectBigQueryInputFormat.createRecordReader(
        InputSplit inputSplit, TaskAttemptContext context)
focal_method.full_signature: @Override public RecordReader<NullWritable, GenericRecord> createRecordReader(
        InputSplit inputSplit, TaskAttemptContext context)
focal_method.identifier: createRecordReader
focal_method.modifiers: @Override public
focal_method.parameters: (
        InputSplit inputSplit, TaskAttemptContext context)
focal_method.return: RecordReader<NullWritable, GenericRecord>
focal_method.signature: RecordReader<NullWritable, GenericRecord> createRecordReader(
        InputSplit inputSplit, TaskAttemptContext context)