Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.backup.master | |
org.apache.hadoop.hbase.client |
Provides HBase Client
|
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.security.access | |
org.apache.hadoop.hbase.thrift2.client | |
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 |
---|---|
private Map<Address,Long> |
BackupLogCleaner.getServersToOldestBackupMapping(List<BackupInfo> backups) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<RSGroupInfo> |
AsyncAdmin.getRSGroup(Address hostPort)
Get group info for the given hostPort
|
CompletableFuture<RSGroupInfo> |
RawAsyncHBaseAdmin.getRSGroup(Address hostPort) |
RSGroupInfo |
Admin.getRSGroup(Address hostPort)
Get group info for the given hostPort
|
RSGroupInfo |
AdminOverAsyncAdmin.getRSGroup(Address hostPort) |
CompletableFuture<RSGroupInfo> |
AsyncHBaseAdmin.getRSGroup(Address hostPort) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
AsyncAdmin.moveServersToRSGroup(Set<Address> servers,
String groupName)
Move given set of servers to the specified target RegionServer group
|
CompletableFuture<Void> |
RawAsyncHBaseAdmin.moveServersToRSGroup(Set<Address> servers,
String groupName) |
void |
Admin.moveServersToRSGroup(Set<Address> servers,
String targetGroup)
Move given set of servers to the specified target RegionServer group
|
void |
AdminOverAsyncAdmin.moveServersToRSGroup(Set<Address> servers,
String groupName) |
CompletableFuture<Void> |
AsyncHBaseAdmin.moveServersToRSGroup(Set<Address> servers,
String groupName) |
CompletableFuture<Void> |
AsyncAdmin.removeServersFromRSGroup(Set<Address> servers)
Remove decommissioned servers from group 1.
|
CompletableFuture<Void> |
RawAsyncHBaseAdmin.removeServersFromRSGroup(Set<Address> servers) |
void |
Admin.removeServersFromRSGroup(Set<Address> servers)
Remove decommissioned servers from group 1.
|
void |
AdminOverAsyncAdmin.removeServersFromRSGroup(Set<Address> servers) |
CompletableFuture<Void> |
AsyncHBaseAdmin.removeServersFromRSGroup(Set<Address> servers) |
Modifier and Type | Method and Description |
---|---|
IpcClientSpanBuilder |
IpcClientSpanBuilder.setRemoteAddress(Address remoteAddress) |
Modifier and Type | Method and Description |
---|---|
default void |
MasterObserver.postGetRSGroupInfoOfServer(ObserverContext<MasterCoprocessorEnvironment> ctx,
Address server)
Called after getting region server group info of the passed server.
|
default void |
MasterObserver.preGetRSGroupInfoOfServer(ObserverContext<MasterCoprocessorEnvironment> ctx,
Address server)
Called before getting region server group info of the passed server.
|
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 |
---|---|
(package 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.postGetRSGroupInfoOfServer(Address server) |
void |
MasterCoprocessorHost.preGetRSGroupInfoOfServer(Address server) |
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 SortedSet<Address> |
RSGroupInfoManagerImpl.getDefaultServers() |
private SortedSet<Address> |
RSGroupInfoManagerImpl.getDefaultServers(List<RSGroupInfo> rsGroupInfoList) |
private Set<Address> |
RSGroupInfoManagerImpl.getOnlineServers()
Returns Set of online Servers named for their hostname and port (not ServerName).
|
private SortedSet<Address> |
DisabledRSGroupInfoManager.getOnlineServers() |
Set<Address> |
RSGroupInfo.getServers()
Get list of servers.
|
Set<Address> |
RSGroupInfoManagerImpl.moveServers(Set<Address> servers,
String srcGroup,
String dstGroup) |
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> |
RSGroupInfoManagerImpl.getRegions(Address server)
Returns List of Regions associated with this
server . |
RSGroupInfo |
RSGroupAdminClient.getRSGroupOfServer(Address hostPort)
Deprecated.
Retrieve the RSGroupInfo a server is affiliated to
|
RSGroupInfo |
RSGroupInfoManager.getRSGroupOfServer(Address serverHostPort)
Gets the group info of server.
|
RSGroupInfo |
RSGroupInfoManagerImpl.getRSGroupOfServer(Address serverHostPort) |
RSGroupInfo |
DisabledRSGroupInfoManager.getRSGroupOfServer(Address serverHostPort) |
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 |
RSGroupInfoManagerImpl.checkForDeadOrOnlineServers(Set<Address> servers)
Check if the set of servers are belong to dead servers list or online servers list.
|
private void |
RSGroupInfoManagerImpl.checkOnlineServersOnly(Set<Address> servers) |
private List<ServerName> |
RSGroupBasedLoadBalancer.filterServers(Set<Address> servers,
List<ServerName> onlineServers)
Filter servers based on the online servers.
|
private <T> void |
RSGroupInfoManagerImpl.moveRegionsBetweenGroups(Set<T> regionsOwners,
Set<Address> newRegionsOwners,
String targetGroupName,
String sourceGroupName,
Function<T,List<RegionInfo>> getRegionsInfo,
Function<RegionInfo,Boolean> validation) |
private void |
RSGroupInfoManagerImpl.moveServerRegionsFromGroup(Set<Address> movedServers,
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 |
RSGroupInfoManagerImpl.moveServerRegionsFromGroup(Set<Address> movedServers,
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 |
RSGroupAdminClient.moveServers(Set<Address> servers,
String targetGroup)
Deprecated.
Move given set of servers to the specified target RegionServer group.
|
void |
RSGroupInfoManager.moveServers(Set<Address> servers,
String targetGroupName)
Move servers to a new group.
|
void |
RSGroupInfoManagerImpl.moveServers(Set<Address> servers,
String targetGroupName) |
void |
DisabledRSGroupInfoManager.moveServers(Set<Address> servers,
String targetGroupName) |
Set<Address> |
RSGroupInfoManagerImpl.moveServers(Set<Address> servers,
String srcGroup,
String dstGroup) |
void |
RSGroupAdminClient.moveServersAndTables(Set<Address> servers,
Set<TableName> tables,
String targetGroup)
Deprecated.
Move given set of servers and tables to the specified target RegionServer group.
|
void |
RSGroupAdminClient.removeServers(Set<Address> servers)
Deprecated.
Remove decommissioned servers from rsgroup.
|
void |
RSGroupInfoManager.removeServers(Set<Address> servers)
Remove decommissioned servers from rsgroup
|
void |
RSGroupInfoManagerImpl.removeServers(Set<Address> servers) |
void |
DisabledRSGroupInfoManager.removeServers(Set<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 |
---|---|
void |
AccessController.preGetRSGroupInfoOfServer(ObserverContext<MasterCoprocessorEnvironment> ctx,
Address server) |
Modifier and Type | Method and Description |
---|---|
void |
AccessController.preMoveServers(ObserverContext<MasterCoprocessorEnvironment> ctx,
Set<Address> servers,
String targetGroup) |
void |
AccessController.preMoveServersAndTables(ObserverContext<MasterCoprocessorEnvironment> ctx,
Set<Address> servers,
Set<TableName> tables,
String targetGroup) |
void |
AccessController.preRemoveServers(ObserverContext<MasterCoprocessorEnvironment> ctx,
Set<Address> servers) |
Modifier and Type | Method and Description |
---|---|
RSGroupInfo |
ThriftAdmin.getRSGroup(Address hostPort) |
Modifier and Type | Method and Description |
---|---|
void |
ThriftAdmin.moveServersToRSGroup(Set<Address> servers,
String targetGroup) |
void |
ThriftAdmin.removeServersFromRSGroup(Set<Address> servers) |
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.