class IndirectBigQueryOutputCommitter extends ForwardingBigQueryFileOutputCommitter {

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

  public  IndirectBigQueryOutputCommitter(TaskAttemptContext context, OutputCommitter delegate);

}