@Test public void testLotsOfMutations() throws Exception { MutateRowsRequest.Entry smallRequest = createRequestEntry(); MutateRowsRequest.Entry.Builder bigRequest = createRequestEntry().toBuilder(); bigRequest.addAllMutations(Collections.nCopies(20_000, bigRequest.getMutations(0))); MutateRowsRequest.Entry lastRequest = bigRequest.clone().setRowKey(ByteString.copyFrom("SomeOtherKey".getBytes())).build(); underTest.add(smallRequest); underTest.add(bigRequest.build()); underTest.add(bigRequest.build()); underTest.add(lastRequest); Assert.assertTrue(underTest.currentBatch.builder.getEntriesList().contains(smallRequest)); underTest.add(lastRequest); Assert.assertFalse(underTest.currentBatch.builder.getEntriesList().contains(smallRequest)); Assert.assertTrue(underTest.currentBatch.builder.getEntriesList().contains(lastRequest)); }
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; }