Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
org.apache.hadoop.hbase.master | |
org.apache.hadoop.hbase.net | |
org.apache.hadoop.hbase.rsgroup | |
org.apache.hadoop.hbase.tmpl.master |
Modifier and Type | Field and Description |
---|---|
private Address |
ServerName.address |
Modifier and Type | Method and Description |
---|---|
Address |
ServerName.getAddress() |
Constructor and Description |
---|
ServerName(Address address,
long startcode) |
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 | 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 | Method and Description |
---|---|
static Address |
Address.fromParts(String hostname,
int port) |
static Address |
Address.fromString(String hostnameAndPort) |
Modifier and Type | Method and Description |
---|---|
int |
Address.compareTo(Address that) |
Modifier and Type | Field and Description |
---|---|
private SortedSet<Address> |
RSGroupInfo.servers |
Modifier and Type | Method and Description |
---|---|
private SortedSet<Address> |
RSGroupInfoManagerImpl.getDefaultServers() |
(package private) static Set<Address> |
Utility.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) |
private List<RegionInfo> |
RSGroupAdminServer.getRegions(Address 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.moveRegionsFromServers(Set<Address> servers,
Set<TableName> tables,
String targetGroupName)
Moves every region from servers which are currently located on these servers,
but should not be located there.
|
private void |
RSGroupAdminServer.moveRegionsToServers(Set<Address> servers,
Set<TableName> tables,
String targetGroupName)
Moves every region of tables which should be kept on the servers,
but currently they are located on other servers.
|
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,
SortedSet<Address> servers,
SortedSet<TableName> tables) |
Modifier and Type | Method and Description |
---|---|
private void |
RSGroupListTmplImpl.__jamon_innerUnit__rsgroup_baseStats(Writer jamonWriter,
RSGroupInfo[] rsGroupInfos,
Map<Address,ServerMetrics> collectServers) |
private void |
RSGroupListTmplImpl.__jamon_innerUnit__rsgroup_compactStats(Writer jamonWriter,
RSGroupInfo[] rsGroupInfos,
Map<Address,ServerMetrics> collectServers) |
private void |
RSGroupListTmplImpl.__jamon_innerUnit__rsgroup_memoryStats(Writer jamonWriter,
RSGroupInfo[] rsGroupInfos,
Map<Address,ServerMetrics> collectServers) |
private void |
RSGroupListTmplImpl.__jamon_innerUnit__rsgroup_requestStats(Writer jamonWriter,
RSGroupInfo[] rsGroupInfos,
Map<Address,ServerMetrics> collectServers) |
private void |
RSGroupListTmplImpl.__jamon_innerUnit__rsgroup_storeStats(Writer jamonWriter,
RSGroupInfo[] rsGroupInfos,
Map<Address,ServerMetrics> collectServers) |
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.