@Test
public void testGetRecordWriter() throws Exception {

  RecordWriter<Text, Text> recordWriter = outputFormat.getRecordWriter(mockTaskAttemptContext);
  // Verify the delegate is being called and the mock RecordWriter is returned.
  assertThat(recordWriter).isEqualTo(mockRecordWriter);
  verify(mockFileOutputFormat).getRecordWriter(eq(mockTaskAttemptContext));
}