org.apache.hadoop.hbase.rsgroup

Interface RSGroupInfoManager

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 long	DEFAULT_REASSIGN_WAIT_INTERVAL
static byte[]	META_FAMILY_BYTES
static byte[]	META_QUALIFIER_BYTES
static java.lang.String	REASSIGN_WAIT_INTERVAL_KEY
static byte[]	ROW_KEY
static TableName	RSGROUP_TABLE_NAME
static java.lang.String	rsGroupZNode

Method Summary

Modifier and Type	Method and Description
void	addRSGroup(RSGroupInfo rsGroupInfo) Add given RSGroupInfo to existing list of group infos.
RSGroupInfo	getRSGroup(java.lang.String groupName) Gets RSGroupInfo for the given group name.
RSGroupInfo	getRSGroupOfServer(Address serverHostPort) 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 existing RSGroupInfos.
java.util.Set<Address>	moveServers(java.util.Set<Address> servers, java.lang.String srcGroup, java.lang.String dstGroup) Move servers to a new group.
void	moveServersAndTables(java.util.Set<Address> servers, java.util.Set<TableName> tables, java.lang.String srcGroup, java.lang.String dstGroup) Move servers and tables 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.
void	removeServers(java.util.Set<Address> servers) Remove decommissioned servers from rsgroup
void	start()

Field Detail

REASSIGN_WAIT_INTERVAL_KEY

static final java.lang.String REASSIGN_WAIT_INTERVAL_KEY

See Also:

Constant Field Values

DEFAULT_REASSIGN_WAIT_INTERVAL

static final long DEFAULT_REASSIGN_WAIT_INTERVAL

See Also:

Constant Field Values

RSGROUP_TABLE_NAME

static final TableName RSGROUP_TABLE_NAME

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

start

void start()

addRSGroup

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

Add given RSGroupInfo to existing list of group infos.

Throws:

java.io.IOException

removeRSGroup

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

Remove a region server group.

Throws:

java.io.IOException

moveServers

java.util.Set<Address> moveServers(java.util.Set<Address> servers,
                                   java.lang.String srcGroup,
                                   java.lang.String dstGroup)
                            throws java.io.IOException

Move servers to a new group.

Parameters:

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

srcGroup - groupName being moved from

dstGroup - groupName being moved to

Returns:

Set of servers moved (May be a subset of servers).

Throws:

java.io.IOException

getRSGroupOfServer

RSGroupInfo getRSGroupOfServer(Address serverHostPort)
                        throws java.io.IOException

Gets the group info of server.

Throws:

java.io.IOException

getRSGroup

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

Gets RSGroupInfo for the given group name.

Throws:

java.io.IOException

getRSGroupOfTable

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

Get the group membership of a table

Throws:

java.io.IOException

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

listRSGroups

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

List the existing RSGroupInfos.

Throws:

java.io.IOException

refresh

void refresh()
      throws java.io.IOException

Refresh/reload the group information from the persistent store

Throws:

java.io.IOException

isOnline

boolean isOnline()

Whether the manager is able to fully return group metadata

Returns:

whether the manager is in online mode

moveServersAndTables

void moveServersAndTables(java.util.Set<Address> servers,
                          java.util.Set<TableName> tables,
                          java.lang.String srcGroup,
                          java.lang.String dstGroup)
                   throws java.io.IOException

Move servers and tables to a new group.

Parameters:

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

tables - set of tables to move

srcGroup - groupName being moved from

dstGroup - groupName being moved to

Throws:

java.io.IOException

removeServers

void removeServers(java.util.Set<Address> servers)
            throws java.io.IOException

Remove decommissioned servers from rsgroup

Parameters:

servers - set of servers to remove

Throws:

java.io.IOException