Package org.apache.hadoop.hbase.rsgroup

Class DisabledRSGroupInfoManager

java.lang.Object

org.apache.hadoop.hbase.rsgroup.DisabledRSGroupInfoManager

All Implemented Interfaces:

RSGroupInfoManager

@Private
class DisabledRSGroupInfoManager
extends Object
implements RSGroupInfoManager

A dummy RSGroupInfoManager which only contains a default rs group.

Field Summary

Fields

Modifier and Type	Field	Description
private final ServerManager	serverManager

Constructor Summary

Constructors

Constructor	Description
DisabledRSGroupInfoManager(ServerManager serverManager)

Method Summary

Modifier and Type	Method	Description
void	addRSGroup(RSGroupInfo rsGroupInfo)	Add given RSGroupInfo to existing list of group infos.
BalanceResponse	balanceRSGroup(String groupName, BalanceRequest request)	Balance a region server group.
String	determineRSGroupInfoForTable(TableName tableName)	Determine RSGroupInfo for the given table.
private SortedSet<Address>	getOnlineServers()
RSGroupInfo	getRSGroup(String groupName)	Gets RSGroupInfo for the given group name.
RSGroupInfo	getRSGroupForTable(TableName tableName)	Get RSGroupInfo for the given table.
RSGroupInfo	getRSGroupOfServer(Address serverHostPort)	Gets the group info of server.
boolean	isOnline()	Whether the manager is able to fully return group metadata
List<RSGroupInfo>	listRSGroups()	List the existing RSGroupInfos.
void	moveServers(Set<Address> servers, String targetGroupName)	Move servers to a new group.
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	setRSGroup(Set<TableName> tables, String groupName)	Set group for tables.
void	start()
void	updateRSGroupConfig(String groupName, Map<String,String> configuration)	Update RSGroup configuration

Methods inherited from class java.lang.Object

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

Field Details

serverManager

private final ServerManager serverManager

Constructor Details

DisabledRSGroupInfoManager

public DisabledRSGroupInfoManager(ServerManager serverManager)

Method Details

start

public void start()

Specified by:

start in interface RSGroupInfoManager

addRSGroup

public void addRSGroup(RSGroupInfo rsGroupInfo)
                throws IOException

Description copied from interface: RSGroupInfoManager

Add given RSGroupInfo to existing list of group infos.

Specified by:

addRSGroup in interface RSGroupInfoManager

Throws:

IOException

removeRSGroup

public void removeRSGroup(String groupName)
                   throws IOException

Description copied from interface: RSGroupInfoManager

Remove a region server group.

Specified by:

removeRSGroup in interface RSGroupInfoManager

Throws:

IOException

moveServers

public void moveServers(Set<Address> servers,
 String targetGroupName)
                 throws IOException

Description copied from interface: RSGroupInfoManager

Move servers to a new group.

Specified by:

moveServers in interface RSGroupInfoManager

Throws:

IOException

getOnlineServers

private SortedSet<Address> getOnlineServers()

getRSGroupOfServer

public RSGroupInfo getRSGroupOfServer(Address serverHostPort)
                               throws IOException

Description copied from interface: RSGroupInfoManager

Gets the group info of server.

Specified by:

getRSGroupOfServer in interface RSGroupInfoManager

Throws:

IOException

getRSGroup

public RSGroupInfo getRSGroup(String groupName)
                       throws IOException

Description copied from interface: RSGroupInfoManager

Gets RSGroupInfo for the given group name.

Specified by:

getRSGroup in interface RSGroupInfoManager

Throws:

IOException

listRSGroups

public List<RSGroupInfo> listRSGroups()
                               throws IOException

Description copied from interface: RSGroupInfoManager

List the existing RSGroupInfos.

Specified by:

listRSGroups in interface RSGroupInfoManager

Throws:

IOException

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

removeServers

public void removeServers(Set<Address> servers)
                   throws IOException

Description copied from interface: RSGroupInfoManager

Remove decommissioned servers from rsgroup

Specified by:

removeServers in interface RSGroupInfoManager

Parameters:

servers - set of servers to remove

Throws:

IOException

getRSGroupForTable

public RSGroupInfo getRSGroupForTable(TableName tableName)
                               throws IOException

Description copied from interface: RSGroupInfoManager

Get RSGroupInfo for the given table.

Specified by:

getRSGroupForTable in interface RSGroupInfoManager

Throws:

IOException

balanceRSGroup

public BalanceResponse balanceRSGroup(String groupName,
 BalanceRequest request)
                               throws IOException

Description copied from interface: RSGroupInfoManager

Balance a region server group.

Specified by:

balanceRSGroup in interface RSGroupInfoManager

Throws:

IOException

setRSGroup

public void setRSGroup(Set<TableName> tables,
 String groupName)
                throws IOException

Description copied from interface: RSGroupInfoManager

Set group for tables.

Specified by:

setRSGroup in interface RSGroupInfoManager

Throws:

IOException

determineRSGroupInfoForTable

public String determineRSGroupInfoForTable(TableName tableName)

Description copied from interface: RSGroupInfoManager

Determine RSGroupInfo for the given table.

Specified by:

determineRSGroupInfoForTable in interface RSGroupInfoManager

Parameters:

tableName - table name

Returns:

rsgroup name

renameRSGroup

public void renameRSGroup(String oldName,
 String newName)
                   throws IOException

Description copied from interface: RSGroupInfoManager

Rename rsgroup

Specified by:

renameRSGroup in interface RSGroupInfoManager

Parameters:

oldName - old rsgroup name

newName - new rsgroup name

Throws:

IOException

updateRSGroupConfig

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

Description copied from interface: RSGroupInfoManager

Update RSGroup configuration

Specified by:

updateRSGroupConfig in interface RSGroupInfoManager

Parameters:

groupName - the group name

configuration - new configuration of the group name to be set

Throws:

IOException - if a remote or network exception occurs