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);
      Optional<BigQueryTableSchema> destSchema = BigQueryOutputConfiguration.getTableSchema(conf);
      BigQueryFileFormat outputFileFormat = BigQueryOutputConfiguration.getFileFormat(conf);
      List<String> sourceUris = getOutputFileURIs();
  
      getBigQueryHelper()
          .importFederatedFromGcs(
              destProjectId,
              destTable,
              destSchema.isPresent() ? destSchema.get().get() : null,
              outputFileFormat,
              sourceUris);
    }
docs: Runs a federated import job on BigQuery for the data in the output path in addition to calling
  the delegate's commitJob.