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_TABLE_SCHEMA =
        new BigQueryTableSchema()
            .setFields(
                ImmutableList.of(
                    new BigQueryTableFieldSchema().setName("Word").setType("STRING"),
                    new BigQueryTableFieldSchema().setName("Count").setType("INTEGER"),
                    new BigQueryTableFieldSchema()
                        .setName("MetaInfo")
                        .setType("RECORD")
                        .setFields(
                            ImmutableList.of(
                                new BigQueryTableFieldSchema()
                                    .setName("NestedField1")
                                    .setType("STRING"),
                                new BigQueryTableFieldSchema()
                                    .setName("NestedField2")
                                    .setType("INTEGER")))))
test_class.modifier: private static final
test_class.original_string: private static final BigQueryTableSchema TEST_TABLE_SCHEMA =
        new BigQueryTableSchema()
            .setFields(
                ImmutableList.of(
                    new BigQueryTableFieldSchema().setName("Word").setType("STRING"),
                    new BigQueryTableFieldSchema().setName("Count").setType("INTEGER"),
                    new BigQueryTableFieldSchema()
                        .setName("MetaInfo")
                        .setType("RECORD")
                        .setFields(
                            ImmutableList.of(
                                new BigQueryTableFieldSchema()
                                    .setName("NestedField1")
                                    .setType("STRING"),
                                new BigQueryTableFieldSchema()
                                    .setName("NestedField2")
                                    .setType("INTEGER")))));
test_class.type: BigQueryTableSchema
test_class.var_name: TEST_TABLE_SCHEMA
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: 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_FILE_STRING = TEST_OUTPUT_PATH_STRING + "test_file"
test_class.modifier: private static final
test_class.original_string: private static final String TEST_OUTPUT_FILE_STRING = TEST_OUTPUT_PATH_STRING + "test_file";
test_class.type: String
test_class.var_name: TEST_OUTPUT_FILE_STRING
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: outputPath
test_class.modifier: private
test_class.original_string: private Path outputPath;
test_class.type: Path
test_class.var_name: outputPath
test_class.declarator: outputSampleFilePath
test_class.modifier: private
test_class.original_string: private Path outputSampleFilePath;
test_class.type: Path
test_class.var_name: outputSampleFilePath
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: committer
test_class.modifier: private
test_class.original_string: private ForwardingBigQueryFileOutputCommitter committer;
test_class.type: ForwardingBigQueryFileOutputCommitter
test_class.var_name: committer
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: mockCommitter
test_class.modifier: @Mock private
test_class.original_string: @Mock private OutputCommitter mockCommitter;
test_class.type: OutputCommitter
test_class.var_name: mockCommitter
test_class.file: bigquery/src/test/java/com/google/cloud/hadoop/io/bigquery/output/ForwardingBigQueryFileOutputCommitterTest.java
test_class.identifier: ForwardingBigQueryFileOutputCommitterTest
test_case.body: @Test
    public void testNeedsTaskCommit() throws IOException {
      // Mock sample return.
      when(mockCommitter.needsTaskCommit(mockTaskAttemptContext)).thenReturn(false);
  
      boolean result = committer.needsTaskCommit(mockTaskAttemptContext);
  
      // Verify the delegate is being called and returns the correct data.
      verify(mockCommitter).needsTaskCommit(eq(mockTaskAttemptContext));
      assertThat(result).isFalse();
    }
test_case.class_method_signature: ForwardingBigQueryFileOutputCommitterTest.testNeedsTaskCommit()
test_case.full_signature: @Test public void testNeedsTaskCommit()
test_case.identifier: testNeedsTaskCommit
test_case.invocations: thenReturn when needsTaskCommit needsTaskCommit needsTaskCommit verify eq isFalse assertThat
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testNeedsTaskCommit()
focal_class.declarator: logger = GoogleLogger.forEnclosingClass()
focal_class.modifier: private static final
focal_class.original_string: private static final GoogleLogger logger = GoogleLogger.forEnclosingClass();
focal_class.type: GoogleLogger
focal_class.var_name: logger
focal_class.declarator: delegate
focal_class.modifier: private final
focal_class.original_string: private final OutputCommitter delegate;
focal_class.type: OutputCommitter
focal_class.var_name: delegate
focal_class.declarator: outputFileSystem
focal_class.modifier: private final
focal_class.original_string: private final FileSystem outputFileSystem;
focal_class.type: FileSystem
focal_class.var_name: outputFileSystem
focal_class.declarator: outputPath
focal_class.modifier: private final
focal_class.original_string: private final Path outputPath;
focal_class.type: Path
focal_class.var_name: outputPath
focal_class.declarator: bigQueryHelper
focal_class.modifier: private
focal_class.original_string: private BigQueryHelper bigQueryHelper;
focal_class.type: BigQueryHelper
focal_class.var_name: bigQueryHelper
focal_class.file: bigquery/src/main/java/com/google/cloud/hadoop/io/bigquery/output/ForwardingBigQueryFileOutputCommitter.java
focal_class.identifier: ForwardingBigQueryFileOutputCommitter
focal_class.class_method_signature: ForwardingBigQueryFileOutputCommitter.ForwardingBigQueryFileOutputCommitter(TaskAttemptContext context, OutputCommitter delegate)
focal_class.full_signature: public  ForwardingBigQueryFileOutputCommitter(TaskAttemptContext context, OutputCommitter delegate)
focal_class.identifier: ForwardingBigQueryFileOutputCommitter
focal_class.modifiers: public
focal_class.parameters: (TaskAttemptContext context, OutputCommitter delegate)
focal_class.signature:  ForwardingBigQueryFileOutputCommitter(TaskAttemptContext context, OutputCommitter delegate)
focal_class.class_method_signature: ForwardingBigQueryFileOutputCommitter.commitJob(JobContext context)
focal_class.full_signature: @Override public void commitJob(JobContext context)
focal_class.identifier: commitJob
focal_class.modifiers: @Override public
focal_class.parameters: (JobContext context)
focal_class.return: void
focal_class.signature: void commitJob(JobContext context)
focal_class.class_method_signature: ForwardingBigQueryFileOutputCommitter.abortJob(JobContext context, State state)
focal_class.full_signature: @Override public void abortJob(JobContext context, State state)
focal_class.identifier: abortJob
focal_class.modifiers: @Override public
focal_class.parameters: (JobContext context, State state)
focal_class.return: void
focal_class.signature: void abortJob(JobContext context, State state)
focal_class.class_method_signature: ForwardingBigQueryFileOutputCommitter.abortTask(TaskAttemptContext context)
focal_class.full_signature: @Override public void abortTask(TaskAttemptContext context)
focal_class.identifier: abortTask
focal_class.modifiers: @Override public
focal_class.parameters: (TaskAttemptContext context)
focal_class.return: void
focal_class.signature: void abortTask(TaskAttemptContext context)
focal_class.class_method_signature: ForwardingBigQueryFileOutputCommitter.commitTask(TaskAttemptContext context)
focal_class.full_signature: @Override public void commitTask(TaskAttemptContext context)
focal_class.identifier: commitTask
focal_class.modifiers: @Override public
focal_class.parameters: (TaskAttemptContext context)
focal_class.return: void
focal_class.signature: void commitTask(TaskAttemptContext context)
focal_class.class_method_signature: ForwardingBigQueryFileOutputCommitter.needsTaskCommit(TaskAttemptContext context)
focal_class.full_signature: @Override public boolean needsTaskCommit(TaskAttemptContext context)
focal_class.identifier: needsTaskCommit
focal_class.modifiers: @Override public
focal_class.parameters: (TaskAttemptContext context)
focal_class.return: boolean
focal_class.signature: boolean needsTaskCommit(TaskAttemptContext context)
focal_class.class_method_signature: ForwardingBigQueryFileOutputCommitter.setupJob(JobContext context)
focal_class.full_signature: @Override public void setupJob(JobContext context)
focal_class.identifier: setupJob
focal_class.modifiers: @Override public
focal_class.parameters: (JobContext context)
focal_class.return: void
focal_class.signature: void setupJob(JobContext context)
focal_class.class_method_signature: ForwardingBigQueryFileOutputCommitter.setupTask(TaskAttemptContext context)
focal_class.full_signature: @Override public void setupTask(TaskAttemptContext context)
focal_class.identifier: setupTask
focal_class.modifiers: @Override public
focal_class.parameters: (TaskAttemptContext context)
focal_class.return: void
focal_class.signature: void setupTask(TaskAttemptContext context)
focal_class.class_method_signature: ForwardingBigQueryFileOutputCommitter.getOutputFileURIs()
focal_class.full_signature: protected List<String> getOutputFileURIs()
focal_class.identifier: getOutputFileURIs
focal_class.modifiers: protected
focal_class.parameters: ()
focal_class.return: List<String>
focal_class.signature: List<String> getOutputFileURIs()
focal_class.class_method_signature: ForwardingBigQueryFileOutputCommitter.cleanup(JobContext context)
focal_class.full_signature: protected void cleanup(JobContext context)
focal_class.identifier: cleanup
focal_class.modifiers: protected
focal_class.parameters: (JobContext context)
focal_class.return: void
focal_class.signature: void cleanup(JobContext context)
focal_class.class_method_signature: ForwardingBigQueryFileOutputCommitter.getDelegate()
focal_class.full_signature: protected OutputCommitter getDelegate()
focal_class.identifier: getDelegate
focal_class.modifiers: protected
focal_class.parameters: ()
focal_class.return: OutputCommitter
focal_class.signature: OutputCommitter getDelegate()
focal_class.class_method_signature: ForwardingBigQueryFileOutputCommitter.getBigQueryHelper()
focal_class.full_signature: protected BigQueryHelper getBigQueryHelper()
focal_class.identifier: getBigQueryHelper
focal_class.modifiers: protected
focal_class.parameters: ()
focal_class.return: BigQueryHelper
focal_class.signature: BigQueryHelper getBigQueryHelper()
focal_class.class_method_signature: ForwardingBigQueryFileOutputCommitter.setBigQueryHelper(BigQueryHelper bigQueryHelper)
focal_class.full_signature: @VisibleForTesting void setBigQueryHelper(BigQueryHelper bigQueryHelper)
focal_class.identifier: setBigQueryHelper
focal_class.modifiers: @VisibleForTesting
focal_class.parameters: (BigQueryHelper bigQueryHelper)
focal_class.return: void
focal_class.signature: void setBigQueryHelper(BigQueryHelper bigQueryHelper)
focal_class.superclass: extends OutputCommitter
focal_method.body: @Override
    public boolean needsTaskCommit(TaskAttemptContext context) throws IOException {
      return delegate.needsTaskCommit(context);
    }
focal_method.class_method_signature: ForwardingBigQueryFileOutputCommitter.needsTaskCommit(TaskAttemptContext context)
focal_method.full_signature: @Override public boolean needsTaskCommit(TaskAttemptContext context)
focal_method.identifier: needsTaskCommit
focal_method.invocations: needsTaskCommit
focal_method.modifiers: @Override public
focal_method.parameters: (TaskAttemptContext context)
focal_method.return: boolean
focal_method.signature: boolean needsTaskCommit(TaskAttemptContext context)