@Test public void testReadFlatRows() { Query query = Query.create(TABLE_ID).range("start", "end"); when(client.readFlatRows(query.toProto(REQUEST_CONTEXT))).thenReturn(mockFlatRow); clientWrapper.readFlatRows(query); verify(client).readFlatRows(query.toProto(REQUEST_CONTEXT)); }
@Override public ResultScanner<FlatRow> readFlatRows(Query request) { return delegate.readFlatRows(request.toProto(requestContext)); }
BigtableDataClientWrapper implements IBigtableDataClient { @Override public ResultScanner<FlatRow> readFlatRows(Query request) { return delegate.readFlatRows(request.toProto(requestContext)); } }
BigtableDataClientWrapper implements IBigtableDataClient { @Override public ResultScanner<FlatRow> readFlatRows(Query request) { return delegate.readFlatRows(request.toProto(requestContext)); } BigtableDataClientWrapper(
      BigtableDataClient bigtableDataClient, RequestContext requestContext); }
BigtableDataClientWrapper implements IBigtableDataClient { @Override public ResultScanner<FlatRow> readFlatRows(Query request) { return delegate.readFlatRows(request.toProto(requestContext)); } BigtableDataClientWrapper(
      BigtableDataClient bigtableDataClient, RequestContext requestContext); @Override void mutateRow(RowMutation rowMutation); @Override ApiFuture<Void> mutateRowAsync(RowMutation rowMutation); @Override Row readModifyWriteRow(ReadModifyWriteRow readModifyWriteRow); @Override ApiFuture<Row> readModifyWriteRowAsync(ReadModifyWriteRow readModifyWriteRow); @Override IBulkMutation createBulkMutationBatcher(String tableId); @Override ApiFuture<Boolean> checkAndMutateRowAsync(ConditionalRowMutation conditionalRowMutation); @Override Boolean checkAndMutateRow(ConditionalRowMutation conditionalRowMutation); @Override List<KeyOffset> sampleRowKeys(String tableId); @Override ApiFuture<List<KeyOffset>> sampleRowKeysAsync(String tableId); @Override ResultScanner<Row> readRows(Query request); @Override ApiFuture<List<Row>> readRowsAsync(Query request); @Override List<FlatRow> readFlatRowsList(Query request); @Override ResultScanner<FlatRow> readFlatRows(Query request); @Override ApiFuture<List<FlatRow>> readFlatRowsAsync(Query request); @Override void readFlatRowsAsync(Query request, StreamObserver<FlatRow> observer); }
BigtableDataClientWrapper implements IBigtableDataClient { @Override public ResultScanner<FlatRow> readFlatRows(Query request) { return delegate.readFlatRows(request.toProto(requestContext)); } BigtableDataClientWrapper(
      BigtableDataClient bigtableDataClient, RequestContext requestContext); @Override void mutateRow(RowMutation rowMutation); @Override ApiFuture<Void> mutateRowAsync(RowMutation rowMutation); @Override Row readModifyWriteRow(ReadModifyWriteRow readModifyWriteRow); @Override ApiFuture<Row> readModifyWriteRowAsync(ReadModifyWriteRow readModifyWriteRow); @Override IBulkMutation createBulkMutationBatcher(String tableId); @Override ApiFuture<Boolean> checkAndMutateRowAsync(ConditionalRowMutation conditionalRowMutation); @Override Boolean checkAndMutateRow(ConditionalRowMutation conditionalRowMutation); @Override List<KeyOffset> sampleRowKeys(String tableId); @Override ApiFuture<List<KeyOffset>> sampleRowKeysAsync(String tableId); @Override ResultScanner<Row> readRows(Query request); @Override ApiFuture<List<Row>> readRowsAsync(Query request); @Override List<FlatRow> readFlatRowsList(Query request); @Override ResultScanner<FlatRow> readFlatRows(Query request); @Override ApiFuture<List<FlatRow>> readFlatRowsAsync(Query request); @Override void readFlatRowsAsync(Query request, StreamObserver<FlatRow> observer);  }