Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.rsgroup |
Modifier and Type | Method and Description |
---|---|
static RSGroupInfo |
RSGroupTableAccessor.getRSGroupInfo(Connection connection,
byte[] rsGroupName) |
private static RSGroupInfo |
RSGroupTableAccessor.getRSGroupInfo(Result result) |
Modifier and Type | Method and Description |
---|---|
static List<RSGroupInfo> |
RSGroupTableAccessor.getAllRSGroupInfo(Connection connection) |
Modifier and Type | Field and Description |
---|---|
private Map<String,RSGroupInfo> |
RSGroupInfoManagerImpl.rsGroupMap |
Modifier and Type | Method and Description |
---|---|
private RSGroupInfo |
RSGroupAdminEndpoint.determineRSGroupInfoForTable(TableDescriptor desc) |
RSGroupInfo |
RSGroupInfoManagerImpl.determineRSGroupInfoForTable(TableName tableName)
Will try to get the rsgroup from
tableMap first then try to get the rsgroup from
script try to get the rsgroup from the NamespaceDescriptor lastly. |
RSGroupInfo |
RSGroupInfoManager.determineRSGroupInfoForTable(TableName tableName)
Determine
RSGroupInfo for the given table. |
private RSGroupInfo |
RSGroupAdminServer.getAndCheckRSGroupInfo(String name)
Check passed name.
|
RSGroupInfo |
RSGroupInfoManagerImpl.getRSGroup(String groupName) |
RSGroupInfo |
RSGroupInfoManager.getRSGroup(String groupName)
Gets
RSGroupInfo for the given group name. |
RSGroupInfo |
RSGroupAdmin.getRSGroupInfo(String groupName)
Gets
RSGroupInfo for given group name. |
RSGroupInfo |
RSGroupAdminServer.getRSGroupInfo(String groupName) |
private RSGroupInfo |
RSGroupInfoManagerImpl.getRSGroupInfo(String groupName) |
RSGroupInfo |
RSGroupAdminClient.getRSGroupInfo(String groupName) |
RSGroupInfo |
RSGroupAdmin.getRSGroupInfoOfTable(TableName tableName)
Gets
RSGroupInfo for the given table's group. |
RSGroupInfo |
RSGroupAdminServer.getRSGroupInfoOfTable(TableName tableName) |
RSGroupInfo |
RSGroupAdminClient.getRSGroupInfoOfTable(TableName tableName) |
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) |
(package private) static RSGroupInfo |
RSGroupProtobufUtil.toGroupInfo(org.apache.hadoop.hbase.protobuf.generated.RSGroupProtos.RSGroupInfo proto) |
Modifier and Type | Method and Description |
---|---|
List<RSGroupInfo> |
RSGroupAdmin.listRSGroups()
Lists current set of RegionServer groups.
|
List<RSGroupInfo> |
RSGroupAdminServer.listRSGroups() |
List<RSGroupInfo> |
RSGroupInfoManagerImpl.listRSGroups() |
List<RSGroupInfo> |
RSGroupInfoManager.listRSGroups()
List the existing
RSGroupInfo s. |
List<RSGroupInfo> |
RSGroupAdminClient.listRSGroups() |
(package private) List<RSGroupInfo> |
RSGroupInfoManagerImpl.retrieveGroupListFromGroupTable() |
(package private) List<RSGroupInfo> |
RSGroupInfoManagerImpl.retrieveGroupListFromZookeeper() |
Modifier and Type | Method and Description |
---|---|
void |
RSGroupInfoManagerImpl.addRSGroup(RSGroupInfo rsGroupInfo) |
void |
RSGroupInfoManager.addRSGroup(RSGroupInfo rsGroupInfo)
Add given RSGroupInfo to existing list of group infos.
|
private List<ServerName> |
RSGroupBasedLoadBalancer.filterOfflineServers(RSGroupInfo RSGroupInfo,
List<ServerName> onlineServers) |
(package private) void |
RSGroupAdminServer.modifyOrMoveTables(Set<TableName> tables,
RSGroupInfo targetGroup) |
private void |
RSGroupAdminServer.moveTableRegionsToGroup(Set<TableName> tables,
RSGroupInfo targetGrp)
Moves regions of tables which are not on target group servers.
|
private void |
RSGroupAdminEndpoint.moveTableToRSGroup(TableDescriptor desc,
RSGroupInfo rsGroupInfo) |
static boolean |
RSGroupUtil.rsGroupHasOnlineServer(MasterServices master,
RSGroupInfo rsGroupInfo) |
(package private) static org.apache.hadoop.hbase.protobuf.generated.RSGroupProtos.RSGroupInfo |
RSGroupProtobufUtil.toProtoGroupInfo(RSGroupInfo pojo) |
private void |
RSGroupAdminEndpoint.validateRSGroup(TableDescriptor desc,
RSGroupInfo rsGroupInfo) |
Modifier and Type | Method and Description |
---|---|
private void |
RSGroupInfoManagerImpl.flushConfig(Map<String,RSGroupInfo> newGroupMap) |
private Map<TableName,String> |
RSGroupInfoManagerImpl.flushConfigTable(Map<String,RSGroupInfo> groupMap) |
private SortedSet<Address> |
RSGroupInfoManagerImpl.getDefaultServers(List<RSGroupInfo> rsGroupInfoList) |
private void |
RSGroupInfoManagerImpl.resetRSGroupAndTableMaps(Map<String,RSGroupInfo> newRSGroupMap,
Map<TableName,String> newTableMap)
Make changes visible.
|
Constructor and Description |
---|
RSGroupInfo(RSGroupInfo src) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.