test_class.declarator: TEST_PROJECT_ID = "domain:project"
test_class.modifier: private static final
test_class.original_string: private static final String TEST_PROJECT_ID = "domain:project";
test_class.type: String
test_class.var_name: TEST_PROJECT_ID
test_class.declarator: TEST_DATASET_ID = "dataset"
test_class.modifier: private static final
test_class.original_string: private static final String TEST_DATASET_ID = "dataset";
test_class.type: String
test_class.var_name: TEST_DATASET_ID
test_class.declarator: TEST_TABLE_ID = "table"
test_class.modifier: private static final
test_class.original_string: private static final String TEST_TABLE_ID = "table";
test_class.type: String
test_class.var_name: TEST_TABLE_ID
test_class.declarator: QUALIFIED_TEST_TABLE_ID =
        String.format("%s:%s.%s", TEST_PROJECT_ID, TEST_DATASET_ID, TEST_TABLE_ID)
test_class.modifier: private static final
test_class.original_string: private static final String QUALIFIED_TEST_TABLE_ID =
        String.format("%s:%s.%s", TEST_PROJECT_ID, TEST_DATASET_ID, TEST_TABLE_ID);
test_class.type: String
test_class.var_name: QUALIFIED_TEST_TABLE_ID
test_class.declarator: TEST_FILE_FORMAT =
        BigQueryFileFormat.NEWLINE_DELIMITED_JSON
test_class.modifier: private static final
test_class.original_string: private static final BigQueryFileFormat TEST_FILE_FORMAT =
        BigQueryFileFormat.NEWLINE_DELIMITED_JSON;
test_class.type: BigQueryFileFormat
test_class.var_name: TEST_FILE_FORMAT
test_class.declarator: TEST_OUTPUT_CLASS = TextOutputFormat.class
test_class.modifier: @SuppressWarnings("rawtypes")
    private static final
test_class.original_string: @SuppressWarnings("rawtypes")
    private static final Class<? extends FileOutputFormat> TEST_OUTPUT_CLASS = TextOutputFormat.class;
test_class.type: Class<? extends FileOutputFormat>
test_class.var_name: TEST_OUTPUT_CLASS
test_class.declarator: TEST_OUTPUT_PATH_STRING = "gs://test_bucket/test_directory/"
test_class.modifier: private static final
test_class.original_string: private static final String TEST_OUTPUT_PATH_STRING = "gs://test_bucket/test_directory/";
test_class.type: String
test_class.var_name: TEST_OUTPUT_PATH_STRING
test_class.declarator: TEST_OUTPUT_PATH = new Path(TEST_OUTPUT_PATH_STRING)
test_class.modifier: private static final
test_class.original_string: private static final Path TEST_OUTPUT_PATH = new Path(TEST_OUTPUT_PATH_STRING);
test_class.type: Path
test_class.var_name: TEST_OUTPUT_PATH
test_class.declarator: TEST_TASK_ATTEMPT_ID =
        new TaskAttemptID(new TaskID("sample_task", 100, false, 200), 1)
test_class.modifier: private static final
test_class.original_string: private static final TaskAttemptID TEST_TASK_ATTEMPT_ID =
        new TaskAttemptID(new TaskID("sample_task", 100, false, 200), 1);
test_class.type: TaskAttemptID
test_class.var_name: TEST_TASK_ATTEMPT_ID
test_class.declarator: ghfs
test_class.modifier: private
test_class.original_string: private InMemoryGoogleHadoopFileSystem ghfs;
test_class.type: InMemoryGoogleHadoopFileSystem
test_class.var_name: ghfs
test_class.declarator: conf
test_class.modifier: private
test_class.original_string: private Configuration conf;
test_class.type: Configuration
test_class.var_name: conf
test_class.declarator: job
test_class.modifier: private
test_class.original_string: private Job job;
test_class.type: Job
test_class.var_name: job
test_class.declarator: outputFormat
test_class.modifier: private
test_class.original_string: private IndirectBigQueryOutputFormat<Text, Text> outputFormat;
test_class.type: IndirectBigQueryOutputFormat<Text, Text>
test_class.var_name: outputFormat
test_class.declarator: mockTaskAttemptContext
test_class.modifier: @Mock private
test_class.original_string: @Mock private TaskAttemptContext mockTaskAttemptContext;
test_class.type: TaskAttemptContext
test_class.var_name: mockTaskAttemptContext
test_class.declarator: mockFileOutputFormat
test_class.modifier: @Mock private
test_class.original_string: @Mock private FileOutputFormat<Text, Text> mockFileOutputFormat;
test_class.type: FileOutputFormat<Text, Text>
test_class.var_name: mockFileOutputFormat
test_class.declarator: mockOutputCommitter
test_class.modifier: @Mock private
test_class.original_string: @Mock private OutputCommitter mockOutputCommitter;
test_class.type: OutputCommitter
test_class.var_name: mockOutputCommitter
test_class.declarator: mockRecordWriter
test_class.modifier: @Mock private
test_class.original_string: @Mock private RecordWriter<Text, Text> mockRecordWriter;
test_class.type: RecordWriter<Text, Text>
test_class.var_name: mockRecordWriter
test_class.file: bigquery/src/test/java/com/google/cloud/hadoop/io/bigquery/output/IndirectBigQueryOutputFormatTest.java
test_class.identifier: IndirectBigQueryOutputFormatTest
test_case.body: @Test
    public void testCreateCommitter() throws IOException {
      IndirectBigQueryOutputCommitter committer =
          (IndirectBigQueryOutputCommitter) outputFormat.createCommitter(mockTaskAttemptContext);
  
      assertThat(committer.getDelegate()).isEqualTo(mockOutputCommitter);
      verify(mockFileOutputFormat).getOutputCommitter(eq(mockTaskAttemptContext));
    }
test_case.class_method_signature: IndirectBigQueryOutputFormatTest.testCreateCommitter()
test_case.full_signature: @Test public void testCreateCommitter()
test_case.identifier: testCreateCommitter
test_case.invocations: createCommitter isEqualTo assertThat getDelegate getOutputCommitter verify eq
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testCreateCommitter()
focal_class.file: bigquery/src/main/java/com/google/cloud/hadoop/io/bigquery/output/IndirectBigQueryOutputFormat.java
focal_class.identifier: IndirectBigQueryOutputFormat
focal_class.class_method_signature: IndirectBigQueryOutputFormat.createCommitter(TaskAttemptContext context)
focal_class.full_signature: @Override public OutputCommitter createCommitter(TaskAttemptContext context)
focal_class.identifier: createCommitter
focal_class.modifiers: @Override public
focal_class.parameters: (TaskAttemptContext context)
focal_class.return: OutputCommitter
focal_class.signature: OutputCommitter createCommitter(TaskAttemptContext context)
focal_class.superclass: extends ForwardingBigQueryFileOutputFormat<K, V>
focal_method.body: @Override
    public OutputCommitter createCommitter(TaskAttemptContext context) throws IOException {
      Configuration conf = context.getConfiguration();
      OutputCommitter delegateCommitter = getDelegate(conf).getOutputCommitter(context);
      OutputCommitter committer = new IndirectBigQueryOutputCommitter(context, delegateCommitter);
      return committer;
    }
focal_method.class_method_signature: IndirectBigQueryOutputFormat.createCommitter(TaskAttemptContext context)
focal_method.full_signature: @Override public OutputCommitter createCommitter(TaskAttemptContext context)
focal_method.identifier: createCommitter
focal_method.invocations: getConfiguration getOutputCommitter getDelegate
focal_method.modifiers: @Override public
focal_method.parameters: (TaskAttemptContext context)
focal_method.return: OutputCommitter
focal_method.signature: OutputCommitter createCommitter(TaskAttemptContext context)