Uses of Class
org.apache.hadoop.hbase.net.Address
Package
Description
Table of Contents
Tools to help define network clients and servers.
-
Uses of Address in org.apache.hadoop.hbase
-
Uses of Address in org.apache.hadoop.hbase.backup.master
Modifier and TypeMethodDescriptionBackupLogCleaner.getServersToOldestBackupMapping
(List<BackupInfo> backups) -
Uses of Address in org.apache.hadoop.hbase.client.trace
-
Uses of Address in org.apache.hadoop.hbase.coprocessor
Modifier and TypeMethodDescriptiondefault void
MasterObserver.postMoveServers
(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers, String targetGroup) Called after servers are moved to target region server groupdefault void
MasterObserver.postMoveServersAndTables
(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers, Set<TableName> tables, String targetGroup) Called after servers are moved to target region server groupdefault void
MasterObserver.postRemoveServers
(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers) Called after servers are removed from rsgroupdefault void
MasterObserver.preMoveServers
(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers, String targetGroup) Called before servers are moved to target region server groupdefault void
MasterObserver.preMoveServersAndTables
(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers, Set<TableName> tables, String targetGroup) Called before servers are moved to target region server groupdefault void
MasterObserver.preRemoveServers
(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers) Called before servers are removed from rsgroup -
Uses of Address in org.apache.hadoop.hbase.ipc
Modifier and TypeFieldDescriptionprotected final Address
AbstractRpcClient.AbstractRpcChannel.addr
(package private) final Address
ConnectionId.address
Modifier and TypeFieldDescriptionprivate static final org.apache.hbase.thirdparty.com.google.common.cache.LoadingCache<Address,
AtomicInteger> AbstractRpcClient.concurrentCounterCache
FailedServers.failedServers
Modifier and TypeMethodDescription(package private) static Address
AbstractRpcClient.createAddr
(ServerName sn) ConnectionId.getAddress()
Modifier and TypeMethodDescriptionvoid
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
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.ModifierConstructorDescriptionprotected
AbstractRpcChannel
(AbstractRpcClient<?> rpcClient, Address addr, User ticket, int rpcTimeout) protected
BlockingRpcChannelImplementation
(AbstractRpcClient<?> rpcClient, Address addr, User ticket, int rpcTimeout) ConnectionId
(User ticket, String serviceName, Address address) protected
RpcChannelImplementation
(AbstractRpcClient<?> rpcClient, Address addr, User ticket, int rpcTimeout) ServerTooBusyException
(Address address, long count) -
Uses of Address in org.apache.hadoop.hbase.master
Modifier and TypeMethodDescriptionvoid
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) -
Uses of Address in org.apache.hadoop.hbase.master.balancer
-
Uses of Address in org.apache.hadoop.hbase.net
Modifier and TypeMethodDescriptionstatic Address
static Address
Address.fromSocketAddress
(InetSocketAddress addr) static Address
Address.fromString
(String hostnameAndPort) Modifier and TypeMethodDescriptionint
static InetSocketAddress
Address.toSocketAddress
(Address addr) static InetSocketAddress[]
Address.toSocketAddress
(Address[] addrs) -
Uses of Address in org.apache.hadoop.hbase.rsgroup
Modifier and TypeMethodDescriptionprivate Address
RSGroupAdminServer.getRegionAddress
(RegionInfo hri) Modifier and TypeMethodDescriptionRSGroupInfoManagerImpl.getDefaultServers()
RSGroupInfoManagerImpl.getDefaultServers
(List<RSGroupInfo> rsGroupInfoList) RSGroupInfoManagerImpl.getOnlineServers
(MasterServices master) RSGroupInfo.getServers()
Get list of servers.RSGroupInfoManager.moveServers
(Set<Address> servers, String srcGroup, String dstGroup) Move servers to a new group.RSGroupInfoManagerImpl.moveServers
(Set<Address> servers, String srcGroup, String dstGroup) Modifier and TypeMethodDescriptionvoid
Adds the given server to the group.boolean
RSGroupInfo.containsServer
(Address hostPort) Returns true if a server with hostPort is foundprivate List<RegionInfo>
RSGroupAdminServer.getRegions
(Address server) Returns List of Regions associated with thisserver
.RSGroupAdmin.getRSGroupOfServer
(Address hostPort) Retrieve the RSGroupInfo a server is affiliated toRSGroupAdminClient.getRSGroupOfServer
(Address hostPort) RSGroupAdminServer.getRSGroupOfServer
(Address hostPort) RSGroupInfoManager.getRSGroupOfServer
(Address serverHostPort) Gets the group info of server.RSGroupInfoManagerImpl.getRSGroupOfServer
(Address serverHostPort) boolean
RSGroupInfo.removeServer
(Address hostPort) Remove given server from the group.Modifier and TypeMethodDescriptionvoid
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.void
RSGroupAdmin.moveServers
(Set<Address> servers, String targetGroup) Move given set of servers to the specified target RegionServer group.void
RSGroupAdminClient.moveServers
(Set<Address> servers, String targetGroup) void
RSGroupAdminServer.moveServers
(Set<Address> servers, String targetGroupName) RSGroupInfoManager.moveServers
(Set<Address> servers, String srcGroup, String dstGroup) Move servers to a new group.RSGroupInfoManagerImpl.moveServers
(Set<Address> servers, String srcGroup, String dstGroup) void
Move given set of servers and tables to the specified target RegionServer group.void
RSGroupAdminClient.moveServersAndTables
(Set<Address> servers, Set<TableName> tables, String targetGroup) void
RSGroupAdminServer.moveServersAndTables
(Set<Address> servers, Set<TableName> tables, String targetGroup) void
RSGroupInfoManager.moveServersAndTables
(Set<Address> servers, Set<TableName> tables, String srcGroup, String dstGroup) Move servers and tables to a new group.void
RSGroupInfoManagerImpl.moveServersAndTables
(Set<Address> servers, Set<TableName> tables, String srcGroup, String dstGroup) void
RSGroupAdmin.removeServers
(Set<Address> servers) Remove decommissioned servers from rsgroup.void
RSGroupAdminClient.removeServers
(Set<Address> servers) void
RSGroupAdminServer.removeServers
(Set<Address> servers) void
RSGroupInfoManager.removeServers
(Set<Address> servers) Remove decommissioned servers from rsgroupvoid
RSGroupInfoManagerImpl.removeServers
(Set<Address> servers) private void
RSGroupInfoManagerImpl.updateDefaultServers
(SortedSet<Address> servers) ModifierConstructorDescription(package private)
RSGroupInfo
(String name, Set<Address> servers) (package private)
Deprecated.Since 3.0.0, will be removed in 4.0.0. -
Uses of Address in org.apache.hadoop.hbase.zookeeper
Modifier and TypeMethodDescriptionMiniZooKeeperCluster.getAddress()
Returns Address for this cluster instance.