class FederatedBigQueryOutputFormat extends ForwardingBigQueryFileOutputFormat<K, V> {

  @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;
  }

}