BigtableSessionSharedThreadPools (Cloud Bigtable HBase Client for Java 0.9.3-SNAPSHOT API)

com.google.cloud.bigtable.grpc

Class BigtableSessionSharedThreadPools

  • java.lang.Object
    • com.google.cloud.bigtable.grpc.BigtableSessionSharedThreadPools


  • public class BigtableSessionSharedThreadPools
    extends Object
    This class contains executors and other thread pool related resources that can be reused across a few BigtableSessions. All executors are automatically expand if there is higher use.
    Version:
    $Id: $Id
    Author:
    sduskis
    • Field Detail

      • BATCH_POOL_THREAD_NAME

        public static final String BATCH_POOL_THREAD_NAME
        Constant BATCH_POOL_THREAD_NAME="bigtable-batch-pool"
        See Also:
        Constant Field Values
      • RETRY_THREADPOOL_NAME

        public static final String RETRY_THREADPOOL_NAME
        Constant RETRY_THREADPOOL_NAME="bigtable-rpc-retry"
        See Also:
        Constant Field Values
      • GRPC_EVENTLOOP_GROUP_NAME

        public static final String GRPC_EVENTLOOP_GROUP_NAME
        Constant GRPC_EVENTLOOP_GROUP_NAME="bigtable-grpc-elg"
        See Also:
        Constant Field Values
      • RETRY_THREAD_COUNT

        public static final int RETRY_THREAD_COUNT
        Number of threads to use to initiate retry calls
        See Also:
        Constant Field Values
      • batchThreadPool

        protected ExecutorService batchThreadPool
        This is used to do pre and post RPC work, and not the i/o itself.
      • elg

        protected io.netty.channel.nio.NioEventLoopGroup elg
        This is needed by nio. We create daemon threads rather than default threads so that if a user shuts down a JVM, the bigtable connection doesn't block the shutdown. By default, the ELG is not a daemon thread pool.
      • retryExecutor

        protected ScheduledExecutorService retryExecutor
        Used for a few cases that benefit from retries, such as puts, gets and scans.
    • Constructor Detail

      • BigtableSessionSharedThreadPools

        protected BigtableSessionSharedThreadPools()

        Constructor for BigtableSessionSharedThreadPools.


Send feedback about...

Cloud Bigtable Documentation