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; }  @Override OutputCommitter createCommitter(TaskAttemptContext context);  }
@Test public void testCreateCommitter() throws IOException { FederatedBigQueryOutputCommitter committer = (FederatedBigQueryOutputCommitter) outputFormat.createCommitter(mockTaskAttemptContext); assertThat(committer.getDelegate()).isEqualTo(mockOutputCommitter); verify(mockFileOutputFormat).getOutputCommitter(eq(mockTaskAttemptContext)); }