org.apache.hadoop.hbase.rsgroup

Class RSGroupInfoManagerImpl

java.lang.Object

org.apache.hadoop.hbase.rsgroup.RSGroupInfoManagerImpl

All Implemented Interfaces:

ServerListener, RSGroupInfoManager

public class RSGroupInfoManagerImpl
extends Object
implements RSGroupInfoManager, ServerListener

This is an implementation of RSGroupInfoManager. Which makes use of an HBase table as the persistence store for the group information. It also makes use of zookeeper to store group information needed for bootstrapping during offline mode.

Field Summary

Fields inherited from interface org.apache.hadoop.hbase.rsgroup.RSGroupInfoManager

META_FAMILY_BYTES, META_QUALIFIER_BYTES, ROW_KEY, RSGROUP_TABLE_NAME, RSGROUP_TABLE_NAME_BYTES, rsGroupZNode

Constructor Summary

Constructors

Constructor and Description
RSGroupInfoManagerImpl(MasterServices master)

Method Summary

Modifier and Type	Method and Description
void	addRSGroup(RSGroupInfo rsGroupInfo) Adds the group.
RSGroupInfo	getRSGroup(String groupName) Gets the group information.
RSGroupInfo	getRSGroupOfServer(HostAndPort hostPort) Gets the group info of server.
String	getRSGroupOfTable(TableName tableName) Get the group membership of a table
boolean	isOnline() Whether the manager is able to fully return group metadata
List<RSGroupInfo>	listRSGroups() List the groups
boolean	moveServers(Set<HostAndPort> hostPorts, String srcGroup, String dstGroup) move servers to a new group.
void	moveTables(Set<TableName> tableNames, String groupName) Set the group membership of a set of tables
void	refresh() Refresh/reload the group information from the persistent store
void	removeRSGroup(String groupName) Delete a region server group.
void	serverAdded(ServerName serverName) The server has joined the cluster.
void	serverRemoved(ServerName serverName) The server was removed from the cluster.

Methods inherited from class java.lang.Object

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

Constructor Detail

RSGroupInfoManagerImpl

public RSGroupInfoManagerImpl(MasterServices master)
                       throws IOException

Throws:

IOException

Method Detail

addRSGroup

public void addRSGroup(RSGroupInfo rsGroupInfo)
                throws IOException

Adds the group.

Specified by:

addRSGroup in interface RSGroupInfoManager

Parameters:

rsGroupInfo - the group name

Throws:

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

moveServers

public boolean moveServers(Set<HostAndPort> hostPorts,
                           String srcGroup,
                           String dstGroup)
                    throws IOException

Description copied from interface: RSGroupInfoManager

move servers to a new group.

Specified by:

moveServers in interface RSGroupInfoManager

Parameters:

hostPorts - list of servers, must be part of the same group

srcGroup - groupName being moved from

dstGroup - groupName being moved to

Returns:

true if move was successful

Throws:

IOException - on move failure

getRSGroupOfServer

public RSGroupInfo getRSGroupOfServer(HostAndPort hostPort)
                               throws IOException

Gets the group info of server.

Specified by:

getRSGroupOfServer in interface RSGroupInfoManager

Parameters:

hostPort - the server

Returns:

An instance of GroupInfo.

Throws:

IOException

getRSGroup

public RSGroupInfo getRSGroup(String groupName)
                       throws IOException

Gets the group information.

Specified by:

getRSGroup in interface RSGroupInfoManager

Parameters:

groupName - the group name

Returns:

An instance of GroupInfo

Throws:

IOException

getRSGroupOfTable

public String getRSGroupOfTable(TableName tableName)
                         throws IOException

Description copied from interface: RSGroupInfoManager

Get the group membership of a table

Specified by:

getRSGroupOfTable in interface RSGroupInfoManager

Parameters:

tableName - name of table to get group membership

Returns:

Group name of table

Throws:

IOException - on failure to retrive information

moveTables

public void moveTables(Set<TableName> tableNames,
                       String groupName)
                throws IOException

Description copied from interface: RSGroupInfoManager

Set the group membership of a set of tables

Specified by:

moveTables in interface RSGroupInfoManager

Parameters:

tableNames - set of tables to move

groupName - name of group of tables to move to

Throws:

IOException - on failure to move

removeRSGroup

public void removeRSGroup(String groupName)
                   throws IOException

Delete a region server group.

Specified by:

removeRSGroup in interface RSGroupInfoManager

Parameters:

groupName - the group name

Throws:

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

listRSGroups

public List<RSGroupInfo> listRSGroups()
                               throws IOException

Description copied from interface: RSGroupInfoManager

List the groups

Specified by:

listRSGroups in interface RSGroupInfoManager

Returns:

list of RSGroupInfo

Throws:

IOException - on failure

isOnline

public boolean isOnline()

Description copied from interface: RSGroupInfoManager

Whether the manager is able to fully return group metadata

Specified by:

isOnline in interface RSGroupInfoManager

Returns:

whether the manager is in online mode

refresh

public void refresh()
             throws IOException

Description copied from interface: RSGroupInfoManager

Refresh/reload the group information from the persistent store

Specified by:

refresh in interface RSGroupInfoManager

Throws:

IOException - on failure to refresh

serverAdded

public void serverAdded(ServerName serverName)

Description copied from interface: ServerListener

The server has joined the cluster.

Specified by:

serverAdded in interface ServerListener

Parameters:

serverName - The remote servers name.

serverRemoved

public void serverRemoved(ServerName serverName)

Description copied from interface: ServerListener

The server was removed from the cluster.

Specified by:

serverRemoved in interface ServerListener

Parameters:

serverName - The remote servers name.