@InterfaceAudience.Private class DisabledRSGroupInfoManager extends Object implements RSGroupInfoManager
Modifier and Type | Field and Description |
---|---|
private ServerManager |
serverManager |
Constructor and Description |
---|
DisabledRSGroupInfoManager(ServerManager serverManager) |
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.
|
String |
determineRSGroupInfoForTable(TableName tableName)
Determine
RSGroupInfo for the given table. |
private SortedSet<Address> |
getOnlineServers() |
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
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
create
private final ServerManager serverManager
public DisabledRSGroupInfoManager(ServerManager serverManager)
public void start()
start
in interface RSGroupInfoManager
public void addRSGroup(RSGroupInfo rsGroupInfo) throws IOException
RSGroupInfoManager
addRSGroup
in interface RSGroupInfoManager
IOException
public void removeRSGroup(String groupName) throws IOException
RSGroupInfoManager
removeRSGroup
in interface RSGroupInfoManager
IOException
public void moveServers(Set<Address> servers, String targetGroupName) throws IOException
RSGroupInfoManager
moveServers
in interface RSGroupInfoManager
IOException
private SortedSet<Address> getOnlineServers()
public RSGroupInfo getRSGroupOfServer(Address serverHostPort) throws IOException
RSGroupInfoManager
getRSGroupOfServer
in interface RSGroupInfoManager
IOException
public RSGroupInfo getRSGroup(String groupName) throws IOException
RSGroupInfoManager
RSGroupInfo
for the given group name.getRSGroup
in interface RSGroupInfoManager
IOException
public List<RSGroupInfo> listRSGroups() throws IOException
RSGroupInfoManager
RSGroupInfo
s.listRSGroups
in interface RSGroupInfoManager
IOException
public boolean isOnline()
RSGroupInfoManager
isOnline
in interface RSGroupInfoManager
public void removeServers(Set<Address> servers) throws IOException
RSGroupInfoManager
removeServers
in interface RSGroupInfoManager
servers
- set of servers to removeIOException
public RSGroupInfo getRSGroupForTable(TableName tableName) throws IOException
RSGroupInfoManager
RSGroupInfo
for the given table.getRSGroupForTable
in interface RSGroupInfoManager
IOException
public BalanceResponse balanceRSGroup(String groupName, BalanceRequest request) throws IOException
RSGroupInfoManager
balanceRSGroup
in interface RSGroupInfoManager
IOException
public void setRSGroup(Set<TableName> tables, String groupName) throws IOException
RSGroupInfoManager
setRSGroup
in interface RSGroupInfoManager
IOException
public String determineRSGroupInfoForTable(TableName tableName)
RSGroupInfoManager
RSGroupInfo
for the given table.determineRSGroupInfoForTable
in interface RSGroupInfoManager
tableName
- table namepublic void renameRSGroup(String oldName, String newName) throws IOException
RSGroupInfoManager
renameRSGroup
in interface RSGroupInfoManager
oldName
- old rsgroup namenewName
- new rsgroup nameIOException
public void updateRSGroupConfig(String groupName, Map<String,String> configuration) throws IOException
RSGroupInfoManager
updateRSGroupConfig
in interface RSGroupInfoManager
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.