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