@Test
public void testCreateBulkMutation() throws Exception {

  RowMutationEntry entry = RowMutationEntry.create(ROW_KEY);
  when(mockDataClient.newBulkMutationBatcher(TABLE_ID)).thenReturn(mockMutationBatcher);
  when(mockMutationBatcher.add(entry)).thenReturn(ApiFutures.<Void>immediateFuture(null));
  BulkMutationWrapper mutationWrapper = dataClientWrapper.createBulkMutation(TABLE_ID);
  mutationWrapper.add(entry).get();
  verify(mockDataClient).newBulkMutationBatcher(TABLE_ID);
  verify(mockMutationBatcher).add(entry);
}