org.apache.hadoop.hbase.rsgroup

Class VerifyingRSGroupAdminClient

java.lang.Object

org.apache.hadoop.hbase.rsgroup.RSGroupAdmin

org.apache.hadoop.hbase.rsgroup.VerifyingRSGroupAdminClient

All Implemented Interfaces:

Closeable, AutoCloseable

public class VerifyingRSGroupAdminClient
extends RSGroupAdmin

Constructor Summary

Constructors

Constructor and Description
VerifyingRSGroupAdminClient(RSGroupAdmin RSGroupAdmin, Configuration conf)

Method Summary

Modifier and Type	Method and Description
void	addRSGroup(String groupName) Add a new group
boolean	balanceRSGroup(String name) Balance the regions in a group
void	close()
RSGroupInfo	getRSGroupInfo(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
List<RSGroupInfo>	listRSGroups() Lists the existing groups.
void	moveServers(Set<HostAndPort> servers, String targetGroup) Move a set of serves to another group
void	moveTables(Set<TableName> tables, String targetGroup) Move tables to a new group.
void	removeRSGroup(String name) Remove a regionserver group
void	verify()

Methods inherited from class org.apache.hadoop.hbase.rsgroup.RSGroupAdmin

newClient

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

VerifyingRSGroupAdminClient

public VerifyingRSGroupAdminClient(RSGroupAdmin RSGroupAdmin,
                                   Configuration conf)
                            throws IOException

Throws:

IOException

Method Detail

addRSGroup

public void addRSGroup(String groupName)
                throws IOException

Description copied from class: RSGroupAdmin

Add a new group

Specified by:

addRSGroup in class RSGroupAdmin

Parameters:

groupName - name of the group

Throws:

IOException - on failure to add group

getRSGroupInfo

public RSGroupInfo getRSGroupInfo(String groupName)
                           throws IOException

Description copied from class: RSGroupAdmin

Gets the regionserver group information.

Specified by:

getRSGroupInfo in class RSGroupAdmin

Parameters:

groupName - the group name

Returns:

An instance of RSGroupInfo

Throws:

IOException

getRSGroupInfoOfTable

public RSGroupInfo getRSGroupInfoOfTable(TableName tableName)
                                  throws IOException

Description copied from class: RSGroupAdmin

Gets the regionserver group info of table.

Specified by:

getRSGroupInfoOfTable in class RSGroupAdmin

Parameters:

tableName - the table name

Returns:

An instance of RSGroupInfo.

Throws:

IOException

moveServers

public void moveServers(Set<HostAndPort> servers,
                        String targetGroup)
                 throws IOException

Description copied from class: RSGroupAdmin

Move a set of serves to another group

Specified by:

moveServers in class RSGroupAdmin

Parameters:

servers - set of servers, must be in the form HOST:PORT

targetGroup - the target group

Throws:

IOException - Signals that an I/O exception has occurred.

moveTables

public void moveTables(Set<TableName> tables,
                       String targetGroup)
                throws IOException

Description copied from class: RSGroupAdmin

Move tables to a new group. This will unassign all of a table's region so it can be reassigned to the correct group.

Specified by:

moveTables in class RSGroupAdmin

Parameters:

tables - list of tables to move

targetGroup - target group

Throws:

IOException - on failure to move tables

removeRSGroup

public void removeRSGroup(String name)
                   throws IOException

Description copied from class: RSGroupAdmin

Remove a regionserver group

Specified by:

removeRSGroup in class RSGroupAdmin

Parameters:

name - name of the group

Throws:

IOException - on failure to remove group

balanceRSGroup

public boolean balanceRSGroup(String name)
                       throws IOException

Description copied from class: RSGroupAdmin

Balance the regions in a group

Specified by:

balanceRSGroup in class RSGroupAdmin

Parameters:

name - the name of the group to balance

Returns:

boolean whether balance ran or not

Throws:

IOException - on unexpected failure to balance group

listRSGroups

public List<RSGroupInfo> listRSGroups()
                               throws IOException

Description copied from class: RSGroupAdmin

Lists the existing groups.

Specified by:

listRSGroups in class RSGroupAdmin

Returns:

Collection of RSGroupInfo.

Throws:

IOException

getRSGroupOfServer

public RSGroupInfo getRSGroupOfServer(HostAndPort hostPort)
                               throws IOException

Description copied from class: RSGroupAdmin

Retrieve the RSGroupInfo a server is affiliated to

Specified by:

getRSGroupOfServer in class RSGroupAdmin

Parameters:

hostPort - HostPort to get RSGroupInfo for

Returns:

RSGroupInfo associated with the server

Throws:

IOException - on unexpected failure to retrieve GroupInfo

verify

public void verify()
            throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException