BulkMutationWrapper (Cloud Bigtable HBase Client for Java 1.12.0 API)

com.google.cloud.bigtable.grpc.async

Class BulkMutationWrapper

• java.lang.Object
• • com.google.cloud.bigtable.grpc.async.BulkMutationWrapper

• All Implemented Interfaces:

  IBulkMutation

  ---

  
  

  public class BulkMutationWrapper
  extends Object
  implements IBulkMutation

  This class wraps existing BulkMutation with Google-cloud-java's model.

• • Constructor Summary

    Constructors 

    Constructor and Description
    BulkMutationWrapper(BulkMutation bulkMutation, com.google.cloud.bigtable.data.v2.internal.RequestContext requestContext)

  • Method Summary

    All Methods Instance Methods Concrete Methods 

    Modifier and Type	Method and Description
    com.google.api.core.ApiFuture<Void>	add(com.google.cloud.bigtable.data.v2.models.RowMutation rowMutation) Adds a RowMutation to the underlying IBulkMutation mechanism.
    void	flush() Sends any outstanding RowMutation and wait until all requests are complete.
    boolean	isFlushed()
    void	sendUnsent() Sends any outstanding RowMutations, present in the current batch.

    • Methods inherited from class java.lang.Object

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

• • Constructor Detail

    • BulkMutationWrapper

      public BulkMutationWrapper(BulkMutation bulkMutation,
                                 com.google.cloud.bigtable.data.v2.internal.RequestContext requestContext)

  • Method Detail

    • add

      public com.google.api.core.ApiFuture<Void> add(com.google.cloud.bigtable.data.v2.models.RowMutation rowMutation)

      Adds a RowMutation to the underlying IBulkMutation mechanism.

      Specified by:

      add in interface IBulkMutation

      Parameters:

      rowMutation - The RowMutation to add.

      Returns:

      a ApiFuture of type Void will be set when request is successful otherwise exception will be thrown.

    • sendUnsent

      public void sendUnsent()

      Sends any outstanding RowMutations, present in the current batch.

      Specified by:

      sendUnsent in interface IBulkMutation

    • flush

      public void flush()
                 throws InterruptedException

      Sends any outstanding RowMutation and wait until all requests are complete.

      Specified by:

      flush in interface IBulkMutation

      Throws:

      InterruptedException

    • isFlushed

      public boolean isFlushed()

      Specified by:

      isFlushed in interface IBulkMutation

      Returns:

      false if there is any outstanding RowMutation that still needs to be sent.