Field Detail

• RANDOM

  private static final Random RANDOM

Constructor Detail

• ConnectionUtils

  public ConnectionUtils()

Method Detail

• getPauseTime

  public static long getPauseTime(long pause,
                  int tries)

  Calculate pause time. Built on HConstants.RETRY_BACKOFF.

  Parameters:

  pause -

  tries -

  Returns:

  How long to wait after tries retries

• injectNonceGeneratorForTesting

  public 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.

• setServerSideHConnectionRetriesConfig

  public static void setServerSideHConnectionRetriesConfig(org.apache.hadoop.conf.Configuration c,
                                           String sn,
                                           org.apache.commons.logging.Log log)

  Changes the configuration to set the number of retries needed when using HConnection internally, e.g. for updating catalog tables, etc. Call this method before we create any Connections.

  Parameters:

  c - The Configuration instance to set the retries into.

  log - Used to log what we set in here.

• createShortCircuitHConnection

  @Deprecated
  public static ClusterConnection createShortCircuitHConnection(Connection conn,
                                                           ServerName serverName,
                                                           org.apache.hadoop.hbase.protobuf.generated.AdminProtos.AdminService.BlockingInterface admin,
                                                           org.apache.hadoop.hbase.protobuf.generated.ClientProtos.ClientService.BlockingInterface client)

  Deprecated. 
  Adapt a HConnection so that it can bypass the RPC layer (serialization, deserialization, networking, etc..) -- i.e. short-circuit -- when talking to a local server.

  Parameters:

  conn - the connection to adapt

  serverName - the local server name

  admin - the admin interface of the local server

  client - the client interface of the local server

  Returns:

  an adapted/decorated HConnection

• createShortCircuitConnection

  public static ClusterConnection createShortCircuitConnection(org.apache.hadoop.conf.Configuration conf,
                                               ExecutorService pool,
                                               User user,
                                               ServerName serverName,
                                               org.apache.hadoop.hbase.protobuf.generated.AdminProtos.AdminService.BlockingInterface admin,
                                               org.apache.hadoop.hbase.protobuf.generated.ClientProtos.ClientService.BlockingInterface client)
                                                        throws IOException

  Creates a short-circuit connection that can bypass the RPC layer (serialization, deserialization, networking, etc..) when talking to a local server.

  Parameters:

  conf - the current configuration

  pool - the thread pool to use for batch operations

  user - the user the connection is for

  serverName - the local server name

  admin - the admin interface of the local server

  client - the client interface of the local server

  Returns:

  a short-circuit connection.

  Throws:

  IOException

• setupMasterlessConnection

  public static void setupMasterlessConnection(org.apache.hadoop.conf.Configuration conf)

  Setup the connection class, so that it will not depend on master being online. Used for testing

  Parameters:

  conf - configuration to set