Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.client.trace | |
org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
org.apache.hadoop.hbase.ipc |
Tools to help define network clients and servers.
|
org.apache.hadoop.hbase.master | |
org.apache.hadoop.hbase.master.balancer | |
org.apache.hadoop.hbase.net | |
org.apache.hadoop.hbase.rsgroup | |
org.apache.hadoop.hbase.zookeeper |
Modifier and Type | Field and Description |
---|---|
private Address |
ServerName.address |
Modifier and Type | Method and Description |
---|---|
Address |
ServerName.getAddress() |
Modifier and Type | Method and Description |
---|---|
static ServerName |
ServerName.valueOf(Address address,
long startCode)
Retrieve an instance of
ServerName . |
Constructor and Description |
---|
ServerName(Address address,
long startCode) |
Modifier and Type | Method and Description |
---|---|
IpcClientSpanBuilder |
IpcClientSpanBuilder.setRemoteAddress(Address remoteAddress) |
Modifier and Type | Method and Description |
---|---|
default void |
MasterObserver.postMoveServers(ObserverContext<MasterCoprocessorEnvironment> ctx,
Set<Address> servers,
String targetGroup)
Called after servers are moved to target region server group
|
default void |
MasterObserver.postMoveServersAndTables(ObserverContext<MasterCoprocessorEnvironment> ctx,
Set<Address> servers,
Set<TableName> tables,
String targetGroup)
Called after servers are moved to target region server group
|
default void |
MasterObserver.postRemoveServers(ObserverContext<MasterCoprocessorEnvironment> ctx,
Set<Address> servers)
Called after servers are removed from rsgroup
|
default void |
MasterObserver.preMoveServers(ObserverContext<MasterCoprocessorEnvironment> ctx,
Set<Address> servers,
String targetGroup)
Called before servers are moved to target region server group
|
default void |
MasterObserver.preMoveServersAndTables(ObserverContext<MasterCoprocessorEnvironment> ctx,
Set<Address> servers,
Set<TableName> tables,
String targetGroup)
Called before servers are moved to target region server group
|
default void |
MasterObserver.preRemoveServers(ObserverContext<MasterCoprocessorEnvironment> ctx,
Set<Address> servers)
Called before servers are removed from rsgroup
|
Modifier and Type | Field and Description |
---|---|
protected Address |
AbstractRpcClient.AbstractRpcChannel.addr |
(package private) Address |
ConnectionId.address |
Modifier and Type | Field and Description |
---|---|
private static org.apache.hbase.thirdparty.com.google.common.cache.LoadingCache<Address,AtomicInteger> |
AbstractRpcClient.concurrentCounterCache |
private Map<Address,Long> |
FailedServers.failedServers |
Modifier and Type | Method and Description |
---|---|
private static Address |
AbstractRpcClient.createAddr(ServerName sn) |
Address |
ConnectionId.getAddress() |
Modifier and Type | Method and Description |
---|---|
void |
FailedServers.addToFailedServers(Address address,
Throwable throwable)
Add an address to the list of the failed servers list.
|
private org.apache.hbase.thirdparty.com.google.protobuf.Message |
AbstractRpcClient.callBlockingMethod(org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
HBaseRpcController hrc,
org.apache.hbase.thirdparty.com.google.protobuf.Message param,
org.apache.hbase.thirdparty.com.google.protobuf.Message returnType,
User ticket,
Address isa)
Make a blocking call.
|
private Call |
AbstractRpcClient.callMethod(org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
HBaseRpcController hrc,
org.apache.hbase.thirdparty.com.google.protobuf.Message param,
org.apache.hbase.thirdparty.com.google.protobuf.Message returnType,
User ticket,
Address addr,
org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<org.apache.hbase.thirdparty.com.google.protobuf.Message> callback) |
private static String |
IPCUtil.getCallTarget(Address addr,
RegionInfo regionInfo) |
static int |
ConnectionId.hashCode(User ticket,
String serviceName,
Address address) |
boolean |
FailedServers.isFailedServer(Address address)
Check if the server should be considered as bad.
|
private void |
AbstractRpcClient.onCallFinished(Call call,
HBaseRpcController hrc,
Address addr,
org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<org.apache.hbase.thirdparty.com.google.protobuf.Message> callback) |
(package private) static IOException |
IPCUtil.wrapException(Address addr,
RegionInfo regionInfo,
Throwable error)
Takes an Exception, the address, and if pertinent, the RegionInfo for the Region we were trying
to connect to and returns an IOException with the input exception as the cause.
|
Constructor and Description |
---|
AbstractRpcChannel(AbstractRpcClient<?> rpcClient,
Address addr,
User ticket,
int rpcTimeout) |
BlockingRpcChannelImplementation(AbstractRpcClient<?> rpcClient,
Address addr,
User ticket,
int rpcTimeout) |
ConnectionId(User ticket,
String serviceName,
Address address) |
RpcChannelImplementation(AbstractRpcClient<?> rpcClient,
Address addr,
User ticket,
int rpcTimeout) |
ServerTooBusyException(Address address,
long count) |
Modifier and Type | Method and Description |
---|---|
void |
MasterCoprocessorHost.postMoveServers(Set<Address> servers,
String targetGroup) |
void |
MasterCoprocessorHost.postMoveServersAndTables(Set<Address> servers,
Set<TableName> tables,
String targetGroup) |
void |
MasterCoprocessorHost.postRemoveServers(Set<Address> servers) |
void |
MasterCoprocessorHost.preMoveServers(Set<Address> servers,
String targetGroup) |
void |
MasterCoprocessorHost.preMoveServersAndTables(Set<Address> servers,
Set<TableName> tables,
String targetGroup) |
void |
MasterCoprocessorHost.preRemoveServers(Set<Address> servers) |
Modifier and Type | Field and Description |
---|---|
(package private) Map<Address,Integer> |
BalancerClusterState.serversToIndex |
Modifier and Type | Method and Description |
---|---|
static Address |
Address.fromParts(String hostname,
int port) |
static Address |
Address.fromSocketAddress(InetSocketAddress addr) |
static Address |
Address.fromString(String hostnameAndPort) |
Modifier and Type | Method and Description |
---|---|
int |
Address.compareTo(Address that) |
static InetSocketAddress |
Address.toSocketAddress(Address addr) |
static InetSocketAddress[] |
Address.toSocketAddress(Address[] addrs) |
Modifier and Type | Field and Description |
---|---|
private SortedSet<Address> |
RSGroupInfo.servers |
Modifier and Type | Method and Description |
---|---|
private Address |
RSGroupAdminServer.getRegionAddress(RegionInfo hri) |
Modifier and Type | Method and Description |
---|---|
private SortedSet<Address> |
RSGroupInfoManagerImpl.getDefaultServers() |
private SortedSet<Address> |
RSGroupInfoManagerImpl.getDefaultServers(List<RSGroupInfo> rsGroupInfoList) |
private static Set<Address> |
RSGroupInfoManagerImpl.getOnlineServers(MasterServices master) |
Set<Address> |
RSGroupInfo.getServers()
Get list of servers.
|
Set<Address> |
RSGroupInfoManagerImpl.moveServers(Set<Address> servers,
String srcGroup,
String dstGroup) |
Set<Address> |
RSGroupInfoManager.moveServers(Set<Address> servers,
String srcGroup,
String dstGroup)
Move servers to a new group.
|
Modifier and Type | Method and Description |
---|---|
void |
RSGroupInfo.addServer(Address hostPort)
Adds the given server to the group.
|
boolean |
RSGroupInfo.containsServer(Address hostPort)
Returns true if a server with hostPort is found
|
private List<RegionInfo> |
RSGroupAdminServer.getRegions(Address server)
Returns List of Regions associated with this
server . |
RSGroupInfo |
RSGroupAdmin.getRSGroupOfServer(Address hostPort)
Retrieve the RSGroupInfo a server is affiliated to
|
RSGroupInfo |
RSGroupAdminServer.getRSGroupOfServer(Address hostPort) |
RSGroupInfo |
RSGroupInfoManagerImpl.getRSGroupOfServer(Address serverHostPort) |
RSGroupInfo |
RSGroupInfoManager.getRSGroupOfServer(Address serverHostPort)
Gets the group info of server.
|
RSGroupInfo |
RSGroupAdminClient.getRSGroupOfServer(Address hostPort) |
boolean |
RSGroupInfo.removeServer(Address hostPort)
Remove given server from the group.
|
Modifier and Type | Method and Description |
---|---|
void |
RSGroupInfo.addAllServers(Collection<Address> hostPort)
Adds the given servers to the group.
|
private void |
RSGroupAdminServer.checkForDeadOrOnlineServers(Set<Address> servers)
Check if the set of servers are belong to dead servers list or online servers list.
|
private void |
RSGroupAdminServer.checkOnlineServersOnly(Set<Address> servers) |
private void |
RSGroupAdminServer.checkServersAndTables(Set<Address> servers,
Set<TableName> tables,
String targetGroupName)
Check servers and tables.
|
private List<ServerName> |
RSGroupBasedLoadBalancer.filterServers(Set<Address> servers,
List<ServerName> onlineServers)
Filter servers based on the online servers.
|
private void |
RSGroupAdminServer.moveServerRegionsFromGroup(Set<Address> movedServers,
Set<TableName> movedTables,
Set<Address> srcGrpServers,
String targetGroupName,
String sourceGroupName)
Move every region from servers which are currently located on these servers, but should not be
located there.
|
private void |
RSGroupAdminServer.moveServerRegionsFromGroup(Set<Address> movedServers,
Set<TableName> movedTables,
Set<Address> srcGrpServers,
String targetGroupName,
String sourceGroupName)
Move every region from servers which are currently located on these servers, but should not be
located there.
|
void |
RSGroupAdmin.moveServers(Set<Address> servers,
String targetGroup)
Move given set of servers to the specified target RegionServer group.
|
void |
RSGroupAdminServer.moveServers(Set<Address> servers,
String targetGroupName) |
void |
RSGroupAdminClient.moveServers(Set<Address> servers,
String targetGroup) |
Set<Address> |
RSGroupInfoManagerImpl.moveServers(Set<Address> servers,
String srcGroup,
String dstGroup) |
Set<Address> |
RSGroupInfoManager.moveServers(Set<Address> servers,
String srcGroup,
String dstGroup)
Move servers to a new group.
|
void |
RSGroupAdmin.moveServersAndTables(Set<Address> servers,
Set<TableName> tables,
String targetGroup)
Move given set of servers and tables to the specified target RegionServer group.
|
void |
RSGroupAdminServer.moveServersAndTables(Set<Address> servers,
Set<TableName> tables,
String targetGroup) |
void |
RSGroupAdminClient.moveServersAndTables(Set<Address> servers,
Set<TableName> tables,
String targetGroup) |
void |
RSGroupInfoManagerImpl.moveServersAndTables(Set<Address> servers,
Set<TableName> tables,
String srcGroup,
String dstGroup) |
void |
RSGroupInfoManager.moveServersAndTables(Set<Address> servers,
Set<TableName> tables,
String srcGroup,
String dstGroup)
Move servers and tables to a new group.
|
void |
RSGroupAdmin.removeServers(Set<Address> servers)
Remove decommissioned servers from rsgroup.
|
void |
RSGroupAdminServer.removeServers(Set<Address> servers) |
void |
RSGroupInfoManagerImpl.removeServers(Set<Address> servers) |
void |
RSGroupInfoManager.removeServers(Set<Address> servers)
Remove decommissioned servers from rsgroup
|
void |
RSGroupAdminClient.removeServers(Set<Address> servers) |
private void |
RSGroupInfoManagerImpl.updateDefaultServers(SortedSet<Address> servers) |
Constructor and Description |
---|
RSGroupInfo(String name,
Set<Address> servers) |
RSGroupInfo(String name,
Set<Address> servers,
Set<TableName> tables)
Deprecated.
Since 3.0.0, will be removed in 4.0.0. The rsgroup information for a table will be
stored in the configuration of a table so this will be removed.
|
Modifier and Type | Method and Description |
---|---|
Address |
MiniZooKeeperCluster.getAddress()
Returns Address for this cluster instance.
|
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.