@Test public void testRequestTimer() { underTest.add(createEntry()); Assert.assertFalse(underTest.currentBatch.wasSent()); underTest.currentBatch.lastRpcSentTimeNanos = time.get(); Assert.assertFalse(underTest.currentBatch.isStale()); time.addAndGet(BulkMutation.MAX_RPC_WAIT_TIME_NANOS - 1); Assert.assertFalse(underTest.currentBatch.isStale()); time.addAndGet(1); Assert.assertTrue(underTest.currentBatch.isStale()); }
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; }