BigtableBufferedMutatorHelper (Cloud Bigtable HBase Client for Java 1.12.0 API)

com.google.cloud.bigtable.hbase

Class BigtableBufferedMutatorHelper

  • java.lang.Object
    • com.google.cloud.bigtable.hbase.BigtableBufferedMutatorHelper


  • public class BigtableBufferedMutatorHelper
    extends Object
    A helper for Bigtable's BufferedMutator implementations.
    Version:
    $Id: $Id
    Author:
    sduskis
    • Field Detail

      • LOG

        protected static final Logger LOG
        Constant LOG
    • Constructor Detail

      • BigtableBufferedMutatorHelper

        public BigtableBufferedMutatorHelper(HBaseRequestAdapter adapter,
                                             org.apache.hadoop.conf.Configuration configuration,
                                             BigtableSession session)
        Constructor for BigtableBufferedMutator.
        Parameters:
        adapter - Converts HBase objects to Bigtable protos
        configuration - For Additional configuration. TODO: move this to options
        session - a BigtableSession object.
    • Method Detail

      • sendUnsent

        public void sendUnsent()
      • getConfiguration

        public org.apache.hadoop.conf.Configuration getConfiguration()
      • getWriteBufferSize

        public long getWriteBufferSize()
      • mutate

        public List<com.google.api.core.ApiFuture<?>> mutate(List<? extends Mutation> mutations)
      • mutate

        public com.google.api.core.ApiFuture<?> mutate(Mutation mutation)
        Being a Mutation. This method will block if either of the following are true: 1) There are more than maxInflightRpcs RPCs in flight 2) There are more than getWriteBufferSize() bytes pending
        Parameters:
        mutation - a Mutation object.
        Returns:
        a ApiFuture object.
      • mutate

        public com.google.api.core.ApiFuture<?> mutate(RowMutations mutation)
        Parameters:
        mutation - a RowMutations object.
        Returns:
        a ApiFuture object.
      • hasInflightRequests

        public boolean hasInflightRequests()
        hasInflightRequests.
        Returns:
        a boolean.