BulkMutation (Cloud Bigtable HBase Client for Java 1.12.0 API)

com.google.cloud.bigtable.grpc.async

Class BulkMutation



  • public class BulkMutation
    extends Object
    This class combines a collection of MutateRowRequests into a single MutateRowsRequest. This class is not thread safe, and requires calling classes to make it thread safe.
    Version:
    $Id: $Id
    Author:
    sduskis
    • Field Detail

      • MAX_RPC_WAIT_TIME_NANOS

        public static final long MAX_RPC_WAIT_TIME_NANOS
      • MAX_NUMBER_OF_MUTATIONS

        public static final long MAX_NUMBER_OF_MUTATIONS
        See Also:
        Constant Field Values
    • Method Detail

      • add

        public ListenableFuture<com.google.bigtable.v2.MutateRowResponse> add(com.google.bigtable.v2.MutateRowRequest request)
      • add

        public ListenableFuture<com.google.bigtable.v2.MutateRowResponse> add(com.google.bigtable.v2.MutateRowsRequest.Entry entry)
        Adds a MutateRowsRequest.Entry to the MutateRowsRequest.Builder.
        Parameters:
        entry - The MutateRowsRequest.Entry to add
        Returns:
        a SettableFuture that will be populated when the MutateRowsResponse returns from the server. See BulkMutation.Batch.addCallback(ListenableFuture) for more information about how the SettableFuture is set.
      • sendUnsent

        public void sendUnsent()
      • isFlushed

        public boolean isFlushed()
        Returns:
        false if there are any outstanding MutateRowRequest that still need to be sent.