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, getParsedServers
public 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
IOException
public static Set<ServerName> parseMasterAddrs(org.apache.hadoop.conf.Configuration conf) throws UnknownHostException
conf
- Configuration to parse from.UnknownHostException
protected Set<ServerName> getBootstrapNodes(org.apache.hadoop.conf.Configuration conf) throws IOException
getBootstrapNodes
in class AbstractRpcBasedConnectionRegistry
IOException
protected CompletableFuture<Set<ServerName>> fetchEndpoints()
fetchEndpoints
in class AbstractRpcBasedConnectionRegistry
public String getConnectionString()
ConnectionRegistry
static String getConnectionString(org.apache.hadoop.conf.Configuration conf) throws UnknownHostException
UnknownHostException
public static String getMasterAddr(org.apache.hadoop.conf.Configuration conf) throws UnknownHostException
HBaseTestingUtility
.UnknownHostException
private 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.