CloudBigtableConnectionPool (Google Cloud Dataflow + Cloud Bigtable Connector 0.3.0 API)

Class CloudBigtableConnectionPool

  • java.lang.Object

  • public class CloudBigtableConnectionPool
    extends Object
    Pubsub and other windowed sources can have a large quantity of bundles in short amounts of time. AbstractCloudBigtableTableDoFn should not create a connection per bundle, since that could happen ever few milliseconds. Rather, it should rely on a connection pool to better manage connection life-cycles.
    • Field Detail

      • LOG

        protected static final org.slf4j.Logger LOG
    • Constructor Detail

      • CloudBigtableConnectionPool

        public CloudBigtableConnectionPool()
    • Method Detail

      • getConnection

        public Connection getConnection(org.apache.hadoop.conf.Configuration config)
                                 throws IOException
        Gets a shared connection where the cluster name from the config is the key.

        NOTE: Do not call close() on the connection, since it's shared.

        config -

Send feedback about...

Cloud Bigtable Documentation