public class VerifyingRSGroupAdminClient extends RSGroupAdmin
Constructor and Description |
---|
VerifyingRSGroupAdminClient(RSGroupAdmin RSGroupAdmin,
Configuration conf) |
Modifier and Type | Method and Description |
---|---|
void |
addRSGroup(java.lang.String groupName)
Add a new group
|
boolean |
balanceRSGroup(java.lang.String name)
Balance the regions in a group
|
void |
close() |
RSGroupInfo |
getRSGroupInfo(java.lang.String groupName)
Gets the regionserver group information.
|
RSGroupInfo |
getRSGroupInfoOfTable(TableName tableName)
Gets the regionserver group info of table.
|
RSGroupInfo |
getRSGroupOfServer(HostAndPort hostPort)
Retrieve the RSGroupInfo a server is affiliated to
|
java.util.List<RSGroupInfo> |
listRSGroups()
Lists the existing groups.
|
void |
moveServers(java.util.Set<HostAndPort> servers,
java.lang.String targetGroup)
Move a set of serves to another group
|
void |
moveTables(java.util.Set<TableName> tables,
java.lang.String targetGroup)
Move tables to a new group.
|
void |
removeRSGroup(java.lang.String name)
Remove a regionserver group
|
void |
verify() |
newClient
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 class RSGroupAdmin
groupName
- name of the groupjava.io.IOException
- on failure to add grouppublic RSGroupInfo getRSGroupInfo(java.lang.String groupName) throws java.io.IOException
RSGroupAdmin
getRSGroupInfo
in class RSGroupAdmin
groupName
- the group namejava.io.IOException
public RSGroupInfo getRSGroupInfoOfTable(TableName tableName) throws java.io.IOException
RSGroupAdmin
getRSGroupInfoOfTable
in class RSGroupAdmin
tableName
- the table namejava.io.IOException
public void moveServers(java.util.Set<HostAndPort> servers, java.lang.String targetGroup) throws java.io.IOException
RSGroupAdmin
moveServers
in class RSGroupAdmin
servers
- set of servers, must be in the form HOST:PORTtargetGroup
- the target groupjava.io.IOException
- Signals that an I/O exception has occurred.public void moveTables(java.util.Set<TableName> tables, java.lang.String targetGroup) throws java.io.IOException
RSGroupAdmin
moveTables
in class RSGroupAdmin
tables
- list of tables to movetargetGroup
- target groupjava.io.IOException
- on failure to move tablespublic void removeRSGroup(java.lang.String name) throws java.io.IOException
RSGroupAdmin
removeRSGroup
in class RSGroupAdmin
name
- name of the groupjava.io.IOException
- on failure to remove grouppublic boolean balanceRSGroup(java.lang.String name) throws java.io.IOException
RSGroupAdmin
balanceRSGroup
in class RSGroupAdmin
name
- the name of the group to balancejava.io.IOException
- on unexpected failure to balance grouppublic java.util.List<RSGroupInfo> listRSGroups() throws java.io.IOException
RSGroupAdmin
listRSGroups
in class RSGroupAdmin
java.io.IOException
public RSGroupInfo getRSGroupOfServer(HostAndPort hostPort) throws java.io.IOException
RSGroupAdmin
getRSGroupOfServer
in class RSGroupAdmin
hostPort
- HostPort to get RSGroupInfo forjava.io.IOException
- on unexpected failure to retrieve GroupInfopublic void verify() throws java.io.IOException
java.io.IOException
public void close() throws java.io.IOException
java.io.IOException