@Test
public void testAddWithFilter() throws ExecutionException, InterruptedException {

  Filters.Filter filter = Filters.FILTERS.family().regex("cf");
  Query query = Query.create(TABLE_ID).rowKey("row-key").filter(filter);
  when(delegate.add(query)).thenReturn(ApiFutures.immediateFuture(FLAT_ROW));
  Result result = bulkReadWrapper.add(ByteString.copyFromUtf8("row-key"), filter).get();
  assertArrayEquals(FLAT_ROW.getRowKey().toByteArray(), result.getRow());
  assertArrayEquals(FLAT_ROW_ADAPTER.adaptResponse(FLAT_ROW).rawCells(), result.rawCells());
  verify(delegate).add(query);
}