@Test public void testCallableSuccess() throws Exception { ListenableFuture<MutateRowResponse> rowFuture = underTest.add(createRequestEntry()); setResponse(Status.OK); MutateRowResponse result = rowFuture.get(10, TimeUnit.MILLISECONDS); Assert.assertTrue(rowFuture.isDone()); Assert.assertEquals(MutateRowResponse.getDefaultInstance(), result); Assert.assertFalse(operationAccountant.hasInflightOperations()); }
public ListenableFuture<MutateRowResponse> add(MutateRowRequest request) { return add(convert(request)); }
BulkMutation { public ListenableFuture<MutateRowResponse> add(MutateRowRequest request) { return add(convert(request)); } }
BulkMutation { public ListenableFuture<MutateRowResponse> add(MutateRowRequest request) { return add(convert(request)); } @InternalApi("For internal usage only")  BulkMutation(
      BigtableTableName tableName,
      BigtableDataClient client,
      ScheduledExecutorService retryExecutorService,
      BulkOptions bulkOptions); @InternalApi("For internal usage only")  BulkMutation(
      BigtableTableName tableName,
      BigtableDataClient client,
      OperationAccountant operationAccountant,
      ScheduledExecutorService retryExecutorService,
      BulkOptions bulkOptions); }
BulkMutation { public ListenableFuture<MutateRowResponse> add(MutateRowRequest request) { return add(convert(request)); } @InternalApi("For internal usage only")  BulkMutation(
      BigtableTableName tableName,
      BigtableDataClient client,
      ScheduledExecutorService retryExecutorService,
      BulkOptions bulkOptions); @InternalApi("For internal usage only")  BulkMutation(
      BigtableTableName tableName,
      BigtableDataClient client,
      OperationAccountant operationAccountant,
      ScheduledExecutorService retryExecutorService,
      BulkOptions bulkOptions); ListenableFuture<MutateRowResponse> add(MutateRowRequest request); synchronized ListenableFuture<MutateRowResponse> add(MutateRowsRequest.Entry entry); void flush(); synchronized void sendUnsent(); boolean isFlushed(); }
BulkMutation { public ListenableFuture<MutateRowResponse> add(MutateRowRequest request) { return add(convert(request)); } @InternalApi("For internal usage only")  BulkMutation(
      BigtableTableName tableName,
      BigtableDataClient client,
      ScheduledExecutorService retryExecutorService,
      BulkOptions bulkOptions); @InternalApi("For internal usage only")  BulkMutation(
      BigtableTableName tableName,
      BigtableDataClient client,
      OperationAccountant operationAccountant,
      ScheduledExecutorService retryExecutorService,
      BulkOptions bulkOptions); ListenableFuture<MutateRowResponse> add(MutateRowRequest request); synchronized ListenableFuture<MutateRowResponse> add(MutateRowsRequest.Entry entry); void flush(); synchronized void sendUnsent(); boolean isFlushed(); @InternalApi("For internal usage only")
  static final long MAX_RPC_WAIT_TIME_NANOS; @InternalApi("For internal usage only")
  static final long MAX_NUMBER_OF_MUTATIONS; }