BulkMutationGCJClient (Cloud Bigtable HBase Client for Java 1.12.0 API)

com.google.cloud.bigtable.grpc.async

Class BulkMutationGCJClient

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

• All Implemented Interfaces:

  IBulkMutation

  ---

  
  

  public class BulkMutationGCJClient
  extends Object
  implements IBulkMutation

  This class is meant to replicate existing BulkMutation while translating calls to Google-Cloud-Java's BulkMutationBatcher api.

• • Constructor Summary

    Constructors 

    Constructor and Description
    BulkMutationGCJClient(com.google.cloud.bigtable.data.v2.models.BulkMutationBatcher bulkMutateBatcher)

  • 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

    • BulkMutationGCJClient

      public BulkMutationGCJClient(com.google.cloud.bigtable.data.v2.models.BulkMutationBatcher bulkMutateBatcher)

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

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

      Specified by:

      flush in interface IBulkMutation

    • isFlushed

      public boolean isFlushed()

      Specified by:

      isFlushed in interface IBulkMutation

      Returns:

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