RpcConnectionRegistry instead.@Deprecated @InterfaceAudience.Private public class MasterRegistry extends AbstractRpcBasedConnectionRegistry
MASTER_REGISTRY_HEDGED_REQS_FANOUT_KEY to a value greater than 1 will enable
it(the default value is AbstractRpcBasedConnectionRegistry.HEDGED_REQS_FANOUT_DEFAULT).
AbstractRpcBasedConnectionRegistry.Callable<T>| Modifier and Type | Field and Description |
|---|---|
private String |
connectionString
Deprecated.
|
private static String |
MASTER_ADDRS_CONF_SEPARATOR
Deprecated.
|
static String |
MASTER_REGISTRY_HEDGED_REQS_FANOUT_KEY
Deprecated.
Configuration key that controls the fan out of requests
|
static String |
MASTER_REGISTRY_INITIAL_REFRESH_DELAY_SECS
Deprecated.
|
static String |
MASTER_REGISTRY_MIN_SECS_BETWEEN_REFRESHES
Deprecated.
|
static String |
MASTER_REGISTRY_PERIODIC_REFRESH_INTERVAL_SECS
Deprecated.
|
HEDGED_REQS_FANOUT_DEFAULT| Constructor and Description |
|---|
MasterRegistry(org.apache.hadoop.conf.Configuration conf)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
protected CompletableFuture<Set<ServerName>> |
fetchEndpoints()
Deprecated.
|
protected Set<ServerName> |
getBootstrapNodes(org.apache.hadoop.conf.Configuration conf)
Deprecated.
|
String |
getConnectionString()
Deprecated.
Return the connection string associated with this registry instance.
|
(package private) static String |
getConnectionString(org.apache.hadoop.conf.Configuration conf)
Deprecated.
|
static String |
getMasterAddr(org.apache.hadoop.conf.Configuration conf)
Deprecated.
Builds the default master address end point if it is not specified in the configuration.
|
(package private) CompletableFuture<Set<ServerName>> |
getMasters()
Deprecated.
|
static Set<ServerName> |
parseMasterAddrs(org.apache.hadoop.conf.Configuration conf)
Deprecated.
Parses the list of master addresses from the provided configuration.
|
private static Set<ServerName> |
transformServerNames(org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetMastersResponse resp)
Deprecated.
|
call, close, getActiveMaster, getClusterId, getMetaRegionLocations, getParsedServerspublic static final String MASTER_REGISTRY_HEDGED_REQS_FANOUT_KEY
public static final String MASTER_REGISTRY_INITIAL_REFRESH_DELAY_SECS
public static final String MASTER_REGISTRY_PERIODIC_REFRESH_INTERVAL_SECS
public static final String MASTER_REGISTRY_MIN_SECS_BETWEEN_REFRESHES
private static final String MASTER_ADDRS_CONF_SEPARATOR
private final String connectionString
MasterRegistry(org.apache.hadoop.conf.Configuration conf) throws IOException
IOExceptionpublic static Set<ServerName> parseMasterAddrs(org.apache.hadoop.conf.Configuration conf) throws UnknownHostException
conf - Configuration to parse from.UnknownHostExceptionprotected Set<ServerName> getBootstrapNodes(org.apache.hadoop.conf.Configuration conf) throws IOException
getBootstrapNodes in class AbstractRpcBasedConnectionRegistryIOExceptionprotected CompletableFuture<Set<ServerName>> fetchEndpoints()
fetchEndpoints in class AbstractRpcBasedConnectionRegistrypublic String getConnectionString()
ConnectionRegistrystatic String getConnectionString(org.apache.hadoop.conf.Configuration conf) throws UnknownHostException
UnknownHostExceptionpublic static String getMasterAddr(org.apache.hadoop.conf.Configuration conf) throws UnknownHostException
HBaseTestingUtility.UnknownHostExceptionprivate static Set<ServerName> transformServerNames(org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetMastersResponse resp)
CompletableFuture<Set<ServerName>> getMasters()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.