@Test public void testGet() throws Exception { when(mockBulkRead.add(any(ByteString.class), any(Filters.Filter.class))).thenReturn(mockFuture); final byte[] key = randomBytes(8); Result response = Result.create( ImmutableList.<Cell>of( new RowCell( key, Bytes.toBytes("family"), Bytes.toBytes(""), 1000L, Bytes.toBytes("value")))); setFuture(response); Result[] results = batch(ImmutableList.<Row>of(new Get(key))); assertTrue(matchesRow(response).matches(results[0])); }
public void batch(List<? extends Row> actions, @Nullable Object[] results) throws IOException, InterruptedException { batchCallback(actions, results, null); }
BatchExecutor { public void batch(List<? extends Row> actions, @Nullable Object[] results) throws IOException, InterruptedException { batchCallback(actions, results, null); } }
BatchExecutor { public void batch(List<? extends Row> actions, @Nullable Object[] results) throws IOException, InterruptedException { batchCallback(actions, results, null); } BatchExecutor(
      BigtableApi bigtableApi, BigtableHBaseSettings settings, HBaseRequestAdapter adapter); }
BatchExecutor { public void batch(List<? extends Row> actions, @Nullable Object[] results) throws IOException, InterruptedException { batchCallback(actions, results, null); } BatchExecutor(
      BigtableApi bigtableApi, BigtableHBaseSettings settings, HBaseRequestAdapter adapter); void batch(List<? extends Row> actions, @Nullable Object[] results); List<ApiFuture<?>> issueAsyncRowRequests(
      List<? extends Row> actions, Object[] results, Batch.Callback<R> callback); Result[] batch(List<? extends Row> actions); void batchCallback(
      List<? extends Row> actions, Object[] results, Batch.Callback<R> callback); boolean[] exists(List<Get> gets); }
BatchExecutor { public void batch(List<? extends Row> actions, @Nullable Object[] results) throws IOException, InterruptedException { batchCallback(actions, results, null); } BatchExecutor(
      BigtableApi bigtableApi, BigtableHBaseSettings settings, HBaseRequestAdapter adapter); void batch(List<? extends Row> actions, @Nullable Object[] results); List<ApiFuture<?>> issueAsyncRowRequests(
      List<? extends Row> actions, Object[] results, Batch.Callback<R> callback); Result[] batch(List<? extends Row> actions); void batchCallback(
      List<? extends Row> actions, Object[] results, Batch.Callback<R> callback); boolean[] exists(List<Get> gets); static final byte[] NO_REGION; }