code: @Override
    public OutputCommitter createCommitter(TaskAttemptContext context) throws IOException {
      Configuration conf = context.getConfiguration();
      OutputCommitter delegateCommitter = getDelegate(conf).getOutputCommitter(context);
      OutputCommitter committer = new FederatedBigQueryOutputCommitter(context, delegateCommitter);
      return committer;
    }
docs: Wraps the delegate's committer in a {@link FederatedBigQueryOutputCommitter}.