@InterfaceAudience.Private public interface RSGroupInfoManager
RSGroupBasedLoadBalancer
.Modifier and Type | Method and Description |
---|---|
void |
addRSGroup(RSGroupInfo rsGroupInfo)
Add given RSGroupInfo to existing list of group infos.
|
BalanceResponse |
balanceRSGroup(String groupName,
BalanceRequest request)
Balance a region server group.
|
static RSGroupInfoManager |
create(MasterServices master) |
String |
determineRSGroupInfoForTable(TableName tableName)
Determine
RSGroupInfo for the given table. |
RSGroupInfo |
getRSGroup(String groupName)
Gets
RSGroupInfo for the given group name. |
RSGroupInfo |
getRSGroupForTable(TableName tableName)
Get
RSGroupInfo for the given table. |
RSGroupInfo |
getRSGroupOfServer(Address serverHostPort)
Gets the group info of server.
|
boolean |
isOnline()
Whether the manager is able to fully return group metadata
|
List<RSGroupInfo> |
listRSGroups()
List the existing
RSGroupInfo s. |
void |
moveServers(Set<Address> servers,
String targetGroupName)
Move servers to a new group.
|
void |
removeRSGroup(String groupName)
Remove a region server group.
|
void |
removeServers(Set<Address> servers)
Remove decommissioned servers from rsgroup
|
void |
renameRSGroup(String oldName,
String newName)
Rename rsgroup
|
void |
setRSGroup(Set<TableName> tables,
String groupName)
Set group for tables.
|
void |
start() |
void |
updateRSGroupConfig(String groupName,
Map<String,String> configuration)
Update RSGroup configuration
|
void start()
void addRSGroup(RSGroupInfo rsGroupInfo) throws IOException
IOException
void removeRSGroup(String groupName) throws IOException
IOException
void moveServers(Set<Address> servers, String targetGroupName) throws IOException
IOException
RSGroupInfo getRSGroupOfServer(Address serverHostPort) throws IOException
IOException
RSGroupInfo getRSGroup(String groupName) throws IOException
RSGroupInfo
for the given group name.IOException
List<RSGroupInfo> listRSGroups() throws IOException
RSGroupInfo
s.IOException
boolean isOnline()
void removeServers(Set<Address> servers) throws IOException
servers
- set of servers to removeIOException
RSGroupInfo getRSGroupForTable(TableName tableName) throws IOException
RSGroupInfo
for the given table.IOException
static RSGroupInfoManager create(MasterServices master) throws IOException
IOException
BalanceResponse balanceRSGroup(String groupName, BalanceRequest request) throws IOException
IOException
void setRSGroup(Set<TableName> tables, String groupName) throws IOException
IOException
String determineRSGroupInfoForTable(TableName tableName)
RSGroupInfo
for the given table.tableName
- table namevoid renameRSGroup(String oldName, String newName) throws IOException
oldName
- old rsgroup namenewName
- new rsgroup nameIOException
void updateRSGroupConfig(String groupName, Map<String,String> configuration) throws IOException
groupName
- the group nameconfiguration
- new configuration of the group name to be setIOException
- if a remote or network exception occursCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.