BigtableBufferedMutator implements BufferedMutator { @Override public void close() throws IOException { helper.close(); handleExceptions(); } BigtableBufferedMutator(
      BigtableApi bigtableApi,
      BigtableHBaseSettings settings,
      HBaseRequestAdapter adapter,
      BufferedMutator.ExceptionListener listener); @Override void close(); @Override void flush(); @Override Configuration getConfiguration(); @Override TableName getName(); @Override long getWriteBufferSize(); @Override void mutate(List<? extends Mutation> mutations); @Override void mutate(Mutation mutation);  }
@Test public void testClose() throws IOException { Configuration config = new Configuration(false); doNothing().when(mockBulkMutation).close(); when(mockBulkMutation.add(any(RowMutationEntry.class))).thenReturn(future); BigtableBufferedMutator underTest = createMutator(config); underTest.mutate(SIMPLE_PUT); underTest.close(); verify(mockBulkMutation).add(any(RowMutationEntry.class)); verify(mockBulkMutation).close(); }