Package org.apache.hadoop.hbase.rsgroup

Interface RSGroupInfoManager

All Known Implementing Classes:

RSGroupInfoManagerImpl

@Private
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	Description
static final long	DEFAULT_REASSIGN_WAIT_INTERVAL
static final byte[]	META_FAMILY_BYTES
static final byte[]	META_QUALIFIER_BYTES
static final String	REASSIGN_WAIT_INTERVAL_KEY
static final byte[]	ROW_KEY
static final TableName	RSGROUP_TABLE_NAME
static final String	rsGroupZNode

Method Summary

Modifier and Type	Method	Description
void	addRSGroup(RSGroupInfo rsGroupInfo)	Add given RSGroupInfo to existing list of group infos.
RSGroupInfo	determineRSGroupInfoForTable(TableName tableName)	Determine RSGroupInfo for the given table.
RSGroupInfo	getRSGroup(String groupName)	Gets RSGroupInfo for the given group name.
RSGroupInfo	getRSGroupOfServer(Address serverHostPort)	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 existing RSGroupInfos.
Set<Address>	moveServers(Set<Address> servers, String srcGroup, String dstGroup)	Move servers to a new group.
void	moveServersAndTables(Set<Address> servers, Set<TableName> tables, String srcGroup, String dstGroup)	Move servers and tables 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)	Remove a region server group.
void	removeServers(Set<Address> servers)	Remove decommissioned servers from rsgroup
void	renameRSGroup(String oldName, String newName)	Rename RSGroup
void	start()
void	updateRSGroupConfig(String groupName, Map<String,String> configuration)	Update RSGroup configuration

Field Details

REASSIGN_WAIT_INTERVAL_KEY

static final 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 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 Details

start

void start()

addRSGroup

void addRSGroup(RSGroupInfo rsGroupInfo)
         throws IOException

Add given RSGroupInfo to existing list of group infos.

Throws:

IOException

removeRSGroup

void removeRSGroup(String groupName)
            throws IOException

Remove a region server group.

Throws:

IOException

moveServers

Set<Address> moveServers(Set<Address> servers,
 String srcGroup,
 String dstGroup)
                  throws 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:

IOException

getRSGroupOfServer

RSGroupInfo getRSGroupOfServer(Address serverHostPort)
                        throws IOException

Gets the group info of server.

Throws:

IOException

getRSGroup

RSGroupInfo getRSGroup(String groupName)
                throws IOException

Gets RSGroupInfo for the given group name.

Throws:

IOException

getRSGroupOfTable

String getRSGroupOfTable(TableName tableName)
                  throws IOException

Get the group membership of a table

Throws:

IOException

moveTables

void moveTables(Set<TableName> tableNames,
 String groupName)
         throws 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:

IOException

listRSGroups

List<RSGroupInfo> listRSGroups()
                        throws IOException

List the existing RSGroupInfos.

Throws:

IOException

refresh

void refresh()
      throws IOException

Refresh/reload the group information from the persistent store

Throws:

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(Set<Address> servers,
 Set<TableName> tables,
 String srcGroup,
 String dstGroup)
                   throws 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:

IOException

removeServers

void removeServers(Set<Address> servers)
            throws IOException

Remove decommissioned servers from rsgroup

Parameters:

servers - set of servers to remove

Throws:

IOException

renameRSGroup

void renameRSGroup(String oldName,
 String newName)
            throws IOException

Rename RSGroup

Parameters:

oldName - old rsgroup name

newName - new rsgroup name

Throws:

IOException

determineRSGroupInfoForTable

RSGroupInfo determineRSGroupInfoForTable(TableName tableName)
                                  throws IOException

Determine RSGroupInfo for the given table.

Parameters:

tableName - table name

Returns:

RSGroupInfo which table should belong to

Throws:

IOException

updateRSGroupConfig

void updateRSGroupConfig(String groupName,
 Map<String,String> configuration)
                  throws IOException

Update RSGroup configuration

Parameters:

groupName - the group name

configuration - new configuration of the group name to be set

Throws:

IOException - if a remote or network exception occurs