org.apache.hadoop.hbase.client

Class RpcConnectionRegistry

java.lang.Object

org.apache.hadoop.hbase.client.AbstractRpcBasedConnectionRegistry

org.apache.hadoop.hbase.client.RpcConnectionRegistry

All Implemented Interfaces:

Closeable, AutoCloseable, ConnectionRegistry

@InterfaceAudience.LimitedPrivate(value="Configuration")
public class RpcConnectionRegistry
extends AbstractRpcBasedConnectionRegistry

Rpc based connection registry. It will make use of the RegistryProtos.ClientMetaService to get registry information.

It needs bootstrap node list when start up, and then it will use RegistryProtos.ClientMetaService to refresh the bootstrap node list periodically.

Usually, you could set masters as the bootstrap nodes,as they will also implement the RegistryProtos.ClientMetaService, and then, we will switch to use region servers after refreshing the bootstrap nodes.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.client.AbstractRpcBasedConnectionRegistry

AbstractRpcBasedConnectionRegistry.Callable<T>

Field Summary

Fields

Modifier and Type	Field and Description
private static char	ADDRS_CONF_SEPARATOR
static String	BOOTSTRAP_NODES
private String	connectionString
static String	HEDGED_REQS_FANOUT_KEY Configuration key that controls the fan out of requests
static String	INITIAL_REFRESH_DELAY_SECS As end users could configure any nodes in a cluster as the initial bootstrap nodes, it is possible that different end users will configure the same machine which makes the machine over load.
static String	MIN_SECS_BETWEEN_REFRESHES
static String	PERIODIC_REFRESH_INTERVAL_SECS

Fields inherited from class org.apache.hadoop.hbase.client.AbstractRpcBasedConnectionRegistry

HEDGED_REQS_FANOUT_DEFAULT

Constructor Summary

Constructors

Constructor and Description
RpcConnectionRegistry(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
private String	buildConnectionString(org.apache.hadoop.conf.Configuration conf)
protected CompletableFuture<Set<ServerName>>	fetchEndpoints()
private CompletableFuture<Set<ServerName>>	getBootstrapNodes()
protected Set<ServerName>	getBootstrapNodes(org.apache.hadoop.conf.Configuration conf)
String	getConnectionString() Return the connection string associated with this registry instance.
private static Set<ServerName>	transformServerNames(org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetBootstrapNodesResponse resp)

Methods inherited from class org.apache.hadoop.hbase.client.AbstractRpcBasedConnectionRegistry

call, close, getActiveMaster, getClusterId, getMetaRegionLocations, getParsedServers

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

HEDGED_REQS_FANOUT_KEY

public static final String HEDGED_REQS_FANOUT_KEY

Configuration key that controls the fan out of requests

See Also:

Constant Field Values

INITIAL_REFRESH_DELAY_SECS

public static final String INITIAL_REFRESH_DELAY_SECS

As end users could configure any nodes in a cluster as the initial bootstrap nodes, it is possible that different end users will configure the same machine which makes the machine over load. So we should have a shorter delay for the initial refresh, to let users quickly switch to the bootstrap nodes we want them to connect to.

The default value for initial refresh delay is 1/10 of periodic refresh interval.

See Also:

Constant Field Values

PERIODIC_REFRESH_INTERVAL_SECS

public static final String PERIODIC_REFRESH_INTERVAL_SECS

See Also:

Constant Field Values

MIN_SECS_BETWEEN_REFRESHES

public static final String MIN_SECS_BETWEEN_REFRESHES

See Also:

Constant Field Values

BOOTSTRAP_NODES

public static final String BOOTSTRAP_NODES

See Also:

Constant Field Values

ADDRS_CONF_SEPARATOR

private static final char ADDRS_CONF_SEPARATOR

See Also:

Constant Field Values

connectionString

private final String connectionString

Constructor Detail

RpcConnectionRegistry

RpcConnectionRegistry(org.apache.hadoop.conf.Configuration conf)
               throws IOException

Throws:

IOException

Method Detail

buildConnectionString

private String buildConnectionString(org.apache.hadoop.conf.Configuration conf)
                              throws UnknownHostException

Throws:

UnknownHostException

getBootstrapNodes

protected Set<ServerName> getBootstrapNodes(org.apache.hadoop.conf.Configuration conf)
                                     throws IOException

Specified by:

getBootstrapNodes in class AbstractRpcBasedConnectionRegistry

Throws:

IOException

getConnectionString

public String getConnectionString()

Description copied from interface: ConnectionRegistry

Return the connection string associated with this registry instance. This value is informational, used for annotating traces. Values returned may not be valid for establishing a working cluster connection.

transformServerNames

private static Set<ServerName> transformServerNames(org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetBootstrapNodesResponse resp)

getBootstrapNodes

private CompletableFuture<Set<ServerName>> getBootstrapNodes()

fetchEndpoints

protected CompletableFuture<Set<ServerName>> fetchEndpoints()

Specified by:

fetchEndpoints in class AbstractRpcBasedConnectionRegistry