code: @Override
    public void commitJob(JobContext context) throws IOException {
      super.commitJob(context);
  
      // Get the destination configuration information.
      Configuration conf = context.getConfiguration();
      TableReference destTable = BigQueryOutputConfiguration.getTableReference(conf);
      String destProjectId = BigQueryOutputConfiguration.getProjectId(conf);
      String writeDisposition = BigQueryOutputConfiguration.getWriteDisposition(conf);
      Optional<BigQueryTableSchema> destSchema = BigQueryOutputConfiguration.getTableSchema(conf);
      String kmsKeyName = BigQueryOutputConfiguration.getKmsKeyName(conf);
      BigQueryFileFormat outputFileFormat = BigQueryOutputConfiguration.getFileFormat(conf);
      List<String> sourceUris = getOutputFileURIs();
  
      try {
        getBigQueryHelper()
            .importFromGcs(
                destProjectId,
                destTable,
                destSchema.isPresent() ? destSchema.get().get() : null,
                kmsKeyName,
                outputFileFormat,
                writeDisposition,
                sourceUris,
                true);
      } catch (InterruptedException e) {
        throw new IOException("Failed to import GCS into BigQuery", e);
      }
  
      cleanup(context);
    }
docs: Runs an import job on BigQuery for the data in the output path in addition to calling the
  delegate's commitJob.