class ForwardingBigQueryFileOutputCommitter extends OutputCommitter {

  @Override
  public void abortJob(JobContext context, State state) throws IOException {
    delegate.abortJob(context, state);
  }

  public  ForwardingBigQueryFileOutputCommitter(TaskAttemptContext context, OutputCommitter delegate);

}