public class VerifyingRSGroupAdminClient extends java.lang.Object implements RSGroupAdmin
Constructor and Description |
---|
VerifyingRSGroupAdminClient(RSGroupAdmin RSGroupAdmin,
Configuration conf) |
Modifier and Type | Method and Description |
---|---|
void |
addRSGroup(java.lang.String groupName)
Creates a new RegionServer group with the given name.
|
boolean |
balanceRSGroup(java.lang.String groupName)
Balance regions in the given RegionServer group.
|
RSGroupInfo |
getRSGroupInfo(java.lang.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
|
java.util.List<RSGroupInfo> |
listRSGroups()
Lists current set of RegionServer groups.
|
void |
moveServers(java.util.Set<Address> servers,
java.lang.String targetGroup)
Move given set of servers to the specified target RegionServer group.
|
void |
moveServersAndTables(java.util.Set<Address> servers,
java.util.Set<TableName> tables,
java.lang.String targetGroup)
Move given set of servers and tables to the specified target RegionServer group.
|
void |
moveTables(java.util.Set<TableName> tables,
java.lang.String targetGroup)
Move given set of tables to the specified target RegionServer group.
|
void |
removeRSGroup(java.lang.String name)
Removes RegionServer group associated with the given name.
|
void |
removeServers(java.util.Set<Address> servers)
Remove decommissioned servers from rsgroup.
|
void |
verify() |
public VerifyingRSGroupAdminClient(RSGroupAdmin RSGroupAdmin, Configuration conf) throws java.io.IOException
java.io.IOException
public void addRSGroup(java.lang.String groupName) throws java.io.IOException
RSGroupAdmin
addRSGroup
in interface RSGroupAdmin
java.io.IOException
public RSGroupInfo getRSGroupInfo(java.lang.String groupName) throws java.io.IOException
RSGroupAdmin
RSGroupInfo
for given group name.getRSGroupInfo
in interface RSGroupAdmin
java.io.IOException
public RSGroupInfo getRSGroupInfoOfTable(TableName tableName) throws java.io.IOException
RSGroupAdmin
RSGroupInfo
for the given table's group.getRSGroupInfoOfTable
in interface RSGroupAdmin
java.io.IOException
public void moveServers(java.util.Set<Address> servers, java.lang.String targetGroup) throws java.io.IOException
RSGroupAdmin
moveServers
in interface RSGroupAdmin
java.io.IOException
public void moveTables(java.util.Set<TableName> tables, java.lang.String targetGroup) throws java.io.IOException
RSGroupAdmin
moveTables
in interface RSGroupAdmin
java.io.IOException
public void removeRSGroup(java.lang.String name) throws java.io.IOException
RSGroupAdmin
removeRSGroup
in interface RSGroupAdmin
java.io.IOException
public boolean balanceRSGroup(java.lang.String groupName) throws java.io.IOException
RSGroupAdmin
balanceRSGroup
in interface RSGroupAdmin
java.io.IOException
public java.util.List<RSGroupInfo> listRSGroups() throws java.io.IOException
RSGroupAdmin
listRSGroups
in interface RSGroupAdmin
java.io.IOException
public RSGroupInfo getRSGroupOfServer(Address hostPort) throws java.io.IOException
RSGroupAdmin
getRSGroupOfServer
in interface RSGroupAdmin
hostPort
- HostPort to get RSGroupInfo forjava.io.IOException
public void moveServersAndTables(java.util.Set<Address> servers, java.util.Set<TableName> tables, java.lang.String targetGroup) throws java.io.IOException
RSGroupAdmin
moveServersAndTables
in interface RSGroupAdmin
servers
- set of servers to movetables
- set of tables to movetargetGroup
- the target group namejava.io.IOException
- if moving the server and tables failpublic void removeServers(java.util.Set<Address> servers) throws java.io.IOException
RSGroupAdmin
removeServers
in interface RSGroupAdmin
servers
- set of servers to removejava.io.IOException
public void verify() throws java.io.IOException
java.io.IOException