ForwardingBigQueryFileOutputFormat extends OutputFormat<K, V> { protected OutputCommitter createCommitter(TaskAttemptContext context) throws IOException { Configuration conf = context.getConfiguration(); return getDelegate(conf).getOutputCommitter(context); }  @Override void checkOutputSpecs(JobContext job); @Override synchronized OutputCommitter getOutputCommitter(TaskAttemptContext context); @Override RecordWriter<K, V> getRecordWriter(TaskAttemptContext context);  }
@Test public void testCreateCommitter() throws IOException { OutputCommitter committer = outputFormat.createCommitter(mockTaskAttemptContext); assertThat(committer).isEqualTo(mockOutputCommitter); verify(mockFileOutputFormat).getOutputCommitter(eq(mockTaskAttemptContext)); }