@Test public void testShutdownService() throws Exception { when(mockFuture.get()).thenThrow(new IllegalStateException("closed")); try { batch(Arrays.asList(randomPut())); } catch (RetriesExhaustedWithDetailsException e) { Assert.assertEquals(1, e.getCauses().size()); Assert.assertEquals(IllegalStateException.class, e.getCause(0).getClass()); } }
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; }