BulkMutation (Cloud Bigtable HBase Client for Java 1.12.0 API)

com.google.cloud.bigtable.grpc.async

Class BulkMutation

• java.lang.Object
• • com.google.cloud.bigtable.grpc.async.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 Summary

    Fields 

    Modifier and Type	Field and Description
    static long	MAX_NUMBER_OF_MUTATIONS
    static long	MAX_RPC_WAIT_TIME_NANOS

  • Constructor Summary

    Constructors 

    Constructor and Description
    BulkMutation(BigtableTableName tableName, BigtableDataClient client, ScheduledExecutorService retryExecutorService, BulkOptions bulkOptions) Constructor for BulkMutation.

  • Method Summary

    All Methods Instance Methods Concrete Methods 

    Modifier and Type	Method and Description
    ListenableFuture<com.google.bigtable.v2.MutateRowResponse>	add(com.google.bigtable.v2.MutateRowRequest request)
    ListenableFuture<com.google.bigtable.v2.MutateRowResponse>	add(com.google.bigtable.v2.MutateRowsRequest.Entry entry) Adds a MutateRowsRequest.Entry to the MutateRowsRequest.Builder.
    void	flush() Send any outstanding MutateRowRequests and wait until all requests are complete.
    boolean	isFlushed()
    void	sendUnsent()

    • Methods inherited from class java.lang.Object

      clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

• • 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

  • Constructor Detail

    • BulkMutation

      public BulkMutation(BigtableTableName tableName,
                          BigtableDataClient client,
                          ScheduledExecutorService retryExecutorService,
                          BulkOptions bulkOptions)

      Constructor for BulkMutation.

      Parameters:

      tableName - a BigtableTableName object for the table to which all MutateRowRequests will be sent.

      client - a BigtableDataClient object on which to perform RPCs. RPCs that this object performed.

      retryExecutorService - a ScheduledExecutorService object on which to schedule retries.

      bulkOptions - a BulkOptions with the user specified options for the behavior of this instance.

  • 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.

    • flush

      public void flush()
                 throws InterruptedException

      Send any outstanding MutateRowRequests and wait until all requests are complete.

      Throws:

      InterruptedException

    • sendUnsent

      public void sendUnsent()

    • isFlushed

      public boolean isFlushed()

      Returns:

      false if there are any outstanding MutateRowRequest that still need to be sent.