org.apache.hadoop.hbase.rsgroup

Class RSGroupAdminServer

java.lang.Object

org.apache.hadoop.hbase.rsgroup.RSGroupAdmin

org.apache.hadoop.hbase.rsgroup.RSGroupAdminServer

All Implemented Interfaces:

Closeable, AutoCloseable

@InterfaceAudience.Private
public class RSGroupAdminServer
extends RSGroupAdmin

Service to support Region Server Grouping (HBase-6721)

Constructor Summary

Constructors

Constructor and Description
RSGroupAdminServer(MasterServices master, RSGroupInfoManager RSGroupInfoManager)

Method Summary

Modifier and Type	Method and Description
void	addRSGroup(String name) Add a new group
boolean	balanceRSGroup(String groupName) Balance the regions in a group
void	cleanupRSGroupForTable(TableName tableName)
void	close()
RSGroupInfo	getRSGroupInfo(String groupName) Gets the regionserver group information.
RSGroupInfoManager	getRSGroupInfoManager()
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 targetGroupName) Move a set of serves to another group
void	moveTables(Set<TableName> tables, String targetGroup) Move tables to a new group.
void	prepareRSGroupForTable(HTableDescriptor desc)
void	removeRSGroup(String name) Remove a regionserver group

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

RSGroupAdminServer

public RSGroupAdminServer(MasterServices master,
                          RSGroupInfoManager RSGroupInfoManager)
                   throws IOException

Throws:

IOException

Method Detail

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 targetGroupName)
                 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

targetGroupName - 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

addRSGroup

public void addRSGroup(String name)
                throws IOException

Description copied from class: RSGroupAdmin

Add a new group

Specified by:

addRSGroup in class RSGroupAdmin

Parameters:

name - name of the group

Throws:

IOException - on failure to add group

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 groupName)
                       throws IOException

Description copied from class: RSGroupAdmin

Balance the regions in a group

Specified by:

balanceRSGroup in class RSGroupAdmin

Parameters:

groupName - 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

getRSGroupInfoManager

@InterfaceAudience.Private
public RSGroupInfoManager getRSGroupInfoManager()
                                                                    throws IOException

Throws:

IOException

prepareRSGroupForTable

public void prepareRSGroupForTable(HTableDescriptor desc)
                            throws IOException

Throws:

IOException

cleanupRSGroupForTable

public void cleanupRSGroupForTable(TableName tableName)
                            throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException