@InterfaceAudience.Private public class RSGroupAdminClient extends Object implements RSGroupAdmin
Modifier and Type | Field and Description |
---|---|
private Admin |
admin |
private org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.RSGroupAdminService.BlockingInterface |
stub |
Constructor and Description |
---|
RSGroupAdminClient(Connection conn) |
Modifier and Type | Method and Description |
---|---|
void |
addRSGroup(String groupName)
Creates a new RegionServer group with the given name.
|
BalanceResponse |
balanceRSGroup(String groupName,
BalanceRequest request)
Balance regions in the given RegionServer group, running based on the given
BalanceRequest . |
RSGroupInfo |
getRSGroupInfo(String groupName)
Gets
RSGroupInfo for given group name. |
RSGroupInfo |
getRSGroupInfoOfTable(TableName tableName)
Gets
RSGroupInfo for the given table's group. |
RSGroupInfo |
getRSGroupOfServer(Address hostPort)
Retrieve the RSGroupInfo a server is affiliated to
|
List<RSGroupInfo> |
listRSGroups()
Lists current set of RegionServer groups.
|
void |
moveServers(Set<Address> servers,
String targetGroup)
Move given set of servers to the specified target RegionServer group.
|
void |
moveServersAndTables(Set<Address> servers,
Set<TableName> tables,
String targetGroup)
Move given set of servers and tables to the specified target RegionServer group.
|
void |
moveTables(Set<TableName> tables,
String targetGroup)
Move given set of tables to the specified target RegionServer group.
|
void |
removeRSGroup(String name)
Removes RegionServer group associated with the given name.
|
void |
removeServers(Set<Address> servers)
Remove decommissioned servers from rsgroup.
|
void |
renameRSGroup(String oldName,
String newName)
Rename rsgroup.
|
void |
updateConfiguration(String groupName)
Update the configuration and trigger an online config change on all the regionservers in the
RSGroup.
|
void |
updateRSGroupConfig(String groupName,
Map<String,String> configuration)
Update RSGroup configuration
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
balanceRSGroup
private org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.RSGroupAdminService.BlockingInterface stub
public RSGroupAdminClient(Connection conn) throws IOException
IOException
public RSGroupInfo getRSGroupInfo(String groupName) throws IOException
RSGroupAdmin
RSGroupInfo
for given group name.getRSGroupInfo
in interface RSGroupAdmin
IOException
public RSGroupInfo getRSGroupInfoOfTable(TableName tableName) throws IOException
RSGroupAdmin
RSGroupInfo
for the given table's group.getRSGroupInfoOfTable
in interface RSGroupAdmin
IOException
public void moveServers(Set<Address> servers, String targetGroup) throws IOException
RSGroupAdmin
moveServers
in interface RSGroupAdmin
IOException
public void moveTables(Set<TableName> tables, String targetGroup) throws IOException
RSGroupAdmin
moveTables
in interface RSGroupAdmin
IOException
public void addRSGroup(String groupName) throws IOException
RSGroupAdmin
addRSGroup
in interface RSGroupAdmin
IOException
public void removeRSGroup(String name) throws IOException
RSGroupAdmin
removeRSGroup
in interface RSGroupAdmin
IOException
public BalanceResponse balanceRSGroup(String groupName, BalanceRequest request) throws IOException
RSGroupAdmin
BalanceRequest
.balanceRSGroup
in interface RSGroupAdmin
IOException
public List<RSGroupInfo> listRSGroups() throws IOException
RSGroupAdmin
listRSGroups
in interface RSGroupAdmin
IOException
public RSGroupInfo getRSGroupOfServer(Address hostPort) throws IOException
RSGroupAdmin
getRSGroupOfServer
in interface RSGroupAdmin
hostPort
- HostPort to get RSGroupInfo forIOException
public void moveServersAndTables(Set<Address> servers, Set<TableName> tables, String targetGroup) throws IOException
RSGroupAdmin
moveServersAndTables
in interface RSGroupAdmin
servers
- set of servers to movetables
- set of tables to movetargetGroup
- the target group nameIOException
- if moving the server and tables failpublic void removeServers(Set<Address> servers) throws IOException
RSGroupAdmin
removeServers
in interface RSGroupAdmin
servers
- set of servers to removeIOException
public void renameRSGroup(String oldName, String newName) throws IOException
RSGroupAdmin
renameRSGroup
in interface RSGroupAdmin
oldName
- old rsgroup namenewName
- new rsgroup nameIOException
public void updateRSGroupConfig(String groupName, Map<String,String> configuration) throws IOException
RSGroupAdmin
updateRSGroupConfig
in interface RSGroupAdmin
groupName
- the group nameconfiguration
- new configuration of the group name to be setIOException
- if a remote or network exception occurspublic void updateConfiguration(String groupName) throws IOException
RSGroupAdmin
updateConfiguration
in interface RSGroupAdmin
groupName
- the group nameIOException
- if a remote or network exception occursCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.