Field Detail

• LOG

  static final org.apache.commons.logging.Log LOG

• RETRIES_BY_SERVER_KEY

  public static final String RETRIES_BY_SERVER_KEY

  See Also:

  Constant Field Values

• CLIENT_NONCES_ENABLED_KEY

  private static final String CLIENT_NONCES_ENABLED_KEY

  See Also:

  Constant Field Values

• RESOLVE_HOSTNAME_ON_FAIL_KEY

  private static final String RESOLVE_HOSTNAME_ON_FAIL_KEY

  See Also:

  Constant Field Values

• CONNECTION_INSTANCES

  static final Map<HConnectionKey,ConnectionManager.HConnectionImplementation> CONNECTION_INSTANCES

• MAX_CACHED_CONNECTION_INSTANCES

  public static final int MAX_CACHED_CONNECTION_INSTANCES

• nonceGenerator

  private static volatile NonceGenerator nonceGenerator

  Global nonceGenerator shared per client.Currently there's no reason to limit its scope. Once it's set under nonceGeneratorCreateLock, it is never unset or changed.

• nonceGeneratorCreateLock

  private static Object nonceGeneratorCreateLock

  The nonce generator lock. Only taken when creating HConnection, which gets a private copy.

Constructor Detail

• ConnectionManager

  private ConnectionManager()

Method Detail

• injectNonceGeneratorForTesting

  static NonceGenerator injectNonceGeneratorForTesting(ClusterConnection conn,
                                              NonceGenerator cnm)

  Parameters:

  conn - The connection for which to replace the generator.

  cnm - Replaces the nonce generator used, for testing.

  Returns:

  old nonce generator.

• getConnection

  @Deprecated
  public static HConnection getConnection(org.apache.hadoop.conf.Configuration conf)
                                   throws IOException

  Deprecated. 
  Get the connection that goes with the passed conf configuration instance. If no current connection exists, method creates a new connection and keys it using connection-specific properties from the passed Configuration; see HConnectionKey.

  Parameters:

  conf - configuration

  Returns:

  HConnection object for conf

  Throws:

  ZooKeeperConnectionException

  IOException

• getConnectionInternal

  static ClusterConnection getConnectionInternal(org.apache.hadoop.conf.Configuration conf)
                                          throws IOException

  Throws:

  IOException

• createConnection

  public static HConnection createConnection(org.apache.hadoop.conf.Configuration conf)
                                      throws IOException

  Create a new HConnection instance using the passed conf instance.

  Note: This bypasses the usual HConnection life cycle management done by getConnection(Configuration). The caller is responsible for calling Connection.close() on the returned connection instance. This is the recommended way to create HConnections. HConnection connection = ConnectionManagerInternal.createConnection(conf); HTableInterface table = connection.getTable("mytable"); table.get(...); ... table.close(); connection.close();

  Parameters:

  conf - configuration

  Returns:

  HConnection object for conf

  Throws:

  ZooKeeperConnectionException

  IOException

• createConnectionInternal

  static ClusterConnection createConnectionInternal(org.apache.hadoop.conf.Configuration conf)
                                             throws IOException

  Throws:

  IOException

• createConnection

  public static HConnection createConnection(org.apache.hadoop.conf.Configuration conf,
                             ExecutorService pool)
                                      throws IOException

  Create a new HConnection instance using the passed conf instance.

  Note: This bypasses the usual HConnection life cycle management done by getConnection(Configuration). The caller is responsible for calling Connection.close() on the returned connection instance. This is the recommended way to create HConnections. ExecutorService pool = ...; HConnection connection = HConnectionManager.createConnection(conf, pool); HTableInterface table = connection.getTable("mytable"); table.get(...); ... table.close(); connection.close();

  Parameters:

  conf - configuration

  pool - the thread pool to use for batch operation in HTables used via this HConnection

  Returns:

  HConnection object for conf

  Throws:

  ZooKeeperConnectionException

  IOException

• createConnection

  public static HConnection createConnection(org.apache.hadoop.conf.Configuration conf,
                             User user)
                                      throws IOException

  Create a new HConnection instance using the passed conf instance.

  Note: This bypasses the usual HConnection life cycle management done by getConnection(Configuration). The caller is responsible for calling Connection.close() on the returned connection instance. This is the recommended way to create HConnections. ExecutorService pool = ...; HConnection connection = HConnectionManager.createConnection(conf, pool); HTableInterface table = connection.getTable("mytable"); table.get(...); ... table.close(); connection.close();

  Parameters:

  conf - configuration

  user - the user the connection is for

  Returns:

  HConnection object for conf

  Throws:

  ZooKeeperConnectionException

  IOException

• createConnection

  public static HConnection createConnection(org.apache.hadoop.conf.Configuration conf,
                             ExecutorService pool,
                             User user)
                                      throws IOException

  Create a new HConnection instance using the passed conf instance.

  Note: This bypasses the usual HConnection life cycle management done by getConnection(Configuration). The caller is responsible for calling Connection.close() on the returned connection instance. This is the recommended way to create HConnections. ExecutorService pool = ...; HConnection connection = HConnectionManager.createConnection(conf, pool); HTableInterface table = connection.getTable("mytable"); table.get(...); ... table.close(); connection.close();

  Parameters:

  conf - configuration

  pool - the thread pool to use for batch operation in HTables used via this HConnection

  user - the user the connection is for

  Returns:

  HConnection object for conf

  Throws:

  ZooKeeperConnectionException

  IOException

• createConnection

  @Deprecated
  static HConnection createConnection(org.apache.hadoop.conf.Configuration conf,
                                        boolean managed)
                               throws IOException

  Deprecated. 

  Throws:

  IOException

• createConnection

  @Deprecated
  static ClusterConnection createConnection(org.apache.hadoop.conf.Configuration conf,
                                              boolean managed,
                                              ExecutorService pool,
                                              User user)
                                     throws IOException

  Deprecated. 

  Throws:

  IOException

• deleteConnection

  @Deprecated
  public static void deleteConnection(org.apache.hadoop.conf.Configuration conf)

  Deprecated. 
  Delete connection information for the instance specified by passed configuration. If there are no more references to the designated connection connection, this method will then close connection to the zookeeper ensemble and let go of all associated resources.

  Parameters:

  conf - configuration whose identity is used to find HConnection instance.

• deleteStaleConnection

  @Deprecated
  public static void deleteStaleConnection(HConnection connection)

  Deprecated. 
  Cleanup a known stale connection. This will then close connection to the zookeeper ensemble and let go of all resources.

  Parameters:

  connection -

• deleteAllConnections

  @Deprecated
  public static void deleteAllConnections(boolean staleConnection)

  Deprecated. 
  Delete information for all connections. Close or not the connection, depending on the staleConnection boolean and the ref count. By default, you should use it with staleConnection to true.

• deleteAllConnections

  @Deprecated
  public static void deleteAllConnections()

  Deprecated. kept for backward compatibility, but the behavior is broken. HBASE-8983
  Delete information for all connections..

• deleteConnection

  @Deprecated
  private static void deleteConnection(HConnection connection,
                                 boolean staleConnection)

  Deprecated. 

• deleteConnection

  @Deprecated
  private static void deleteConnection(HConnectionKey connectionKey,
                                 boolean staleConnection)

  Deprecated. 

• execute

  @InterfaceAudience.Private
  public static <T> T execute(HConnectable<T> connectable)
                   throws IOException

  This convenience method invokes the given HConnectable.connect(org.apache.hadoop.hbase.client.HConnection) implementation using a HConnection instance that lasts just for the duration of the invocation.

  Type Parameters:

  T - the return type of the connect method

  Parameters:

  connectable - the HConnectable instance

  Returns:

  the value returned by the connect method

  Throws:

  IOException