@Test
public void testCreateBulkRead() throws Exception {

  when(mockDataClient.newBulkReadRowsBatcher(TABLE_ID, null)).thenReturn(mockReadBatcher);
  when(mockReadBatcher.add(ROW_KEY)).thenReturn(ApiFutures.immediateFuture(MODEL_ROW));
  BulkReadWrapper bulkReadWrapper = dataClientWrapper.createBulkRead(TABLE_ID);
  assertResult(EXPECTED_RESULT, bulkReadWrapper.add(ROW_KEY, null).get());
  verify(mockDataClient).newBulkReadRowsBatcher(TABLE_ID, null);
  verify(mockReadBatcher).add(ROW_KEY);
}