org.apache.hadoop.hbase.rsgroup

Interface RSGroupInfoManager

All Known Implementing Classes:

RSGroupInfoManagerImpl

public interface RSGroupInfoManager

Interface used to manage RSGroupInfo storage. An implementation has the option to support offline mode. See RSGroupBasedLoadBalancer

Field Summary

Fields

Modifier and Type	Field and Description
static byte[]	META_FAMILY_BYTES
static byte[]	META_QUALIFIER_BYTES
static byte[]	ROW_KEY
static TableName	RSGROUP_TABLE_NAME
static byte[]	RSGROUP_TABLE_NAME_BYTES
static java.lang.String	rsGroupZNode

Method Summary

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

Field Detail

RSGROUP_TABLE_NAME

static final TableName RSGROUP_TABLE_NAME

RSGROUP_TABLE_NAME_BYTES

static final byte[] RSGROUP_TABLE_NAME_BYTES

rsGroupZNode

static final java.lang.String rsGroupZNode

See Also:

Constant Field Values

META_FAMILY_BYTES

static final byte[] META_FAMILY_BYTES

META_QUALIFIER_BYTES

static final byte[] META_QUALIFIER_BYTES

ROW_KEY

static final byte[] ROW_KEY

Method Detail

addRSGroup

void addRSGroup(RSGroupInfo rsGroupInfo)
         throws java.io.IOException

Adds the group.

Parameters:

rsGroupInfo - the group name

Throws:

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

removeRSGroup

void removeRSGroup(java.lang.String groupName)
            throws java.io.IOException

Remove a region server group.

Parameters:

groupName - the group name

Throws:

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

moveServers

boolean moveServers(java.util.Set<HostAndPort> hostPorts,
                    java.lang.String srcGroup,
                    java.lang.String dstGroup)
             throws java.io.IOException

move servers to a new group.

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:

java.io.IOException - on move failure

getRSGroupOfServer

RSGroupInfo getRSGroupOfServer(HostAndPort hostPort)
                        throws java.io.IOException

Gets the group info of server.

Parameters:

hostPort - the server

Returns:

An instance of RSGroupInfo

Throws:

java.io.IOException

getRSGroup

RSGroupInfo getRSGroup(java.lang.String groupName)
                throws java.io.IOException

Gets the group information.

Parameters:

groupName - the group name

Returns:

An instance of RSGroupInfo

Throws:

java.io.IOException

getRSGroupOfTable

java.lang.String getRSGroupOfTable(TableName tableName)
                            throws java.io.IOException

Get the group membership of a table

Parameters:

tableName - name of table to get group membership

Returns:

Group name of table

Throws:

java.io.IOException - on failure to retrive information

moveTables

void moveTables(java.util.Set<TableName> tableNames,
                java.lang.String groupName)
         throws java.io.IOException

Set the group membership of a set of tables

Parameters:

tableNames - set of tables to move

groupName - name of group of tables to move to

Throws:

java.io.IOException - on failure to move

listRSGroups

java.util.List<RSGroupInfo> listRSGroups()
                                  throws java.io.IOException

List the groups

Returns:

list of RSGroupInfo

Throws:

java.io.IOException - on failure

refresh

void refresh()
      throws java.io.IOException

Refresh/reload the group information from the persistent store

Throws:

java.io.IOException - on failure to refresh

isOnline

boolean isOnline()

Whether the manager is able to fully return group metadata

Returns:

whether the manager is in online mode