Package org.apache.hadoop.hbase.rsgroup

Class VerifyingRSGroupAdminClient

java.lang.Object

org.apache.hadoop.hbase.rsgroup.VerifyingRSGroupAdminClient

All Implemented Interfaces:

org.apache.hadoop.hbase.rsgroup.RSGroupAdmin

@Private
public class VerifyingRSGroupAdminClient
extends Object
implements org.apache.hadoop.hbase.rsgroup.RSGroupAdmin

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.hbase.client.Table	table
private org.apache.hadoop.hbase.rsgroup.RSGroupAdmin	wrapped
private org.apache.hadoop.hbase.zookeeper.ZKWatcher	zkw

Constructor Summary

Constructors

Constructor	Description
VerifyingRSGroupAdminClient(org.apache.hadoop.hbase.rsgroup.RSGroupAdmin RSGroupAdmin, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
void	addRSGroup(String groupName)
org.apache.hadoop.hbase.client.BalanceResponse	balanceRSGroup(String groupName, org.apache.hadoop.hbase.client.BalanceRequest request)
org.apache.hadoop.hbase.rsgroup.RSGroupInfo	getRSGroupInfo(String groupName)
org.apache.hadoop.hbase.rsgroup.RSGroupInfo	getRSGroupInfoOfTable(org.apache.hadoop.hbase.TableName tableName)
org.apache.hadoop.hbase.rsgroup.RSGroupInfo	getRSGroupOfServer(org.apache.hadoop.hbase.net.Address hostPort)
List<org.apache.hadoop.hbase.rsgroup.RSGroupInfo>	listRSGroups()
void	moveServers(Set<org.apache.hadoop.hbase.net.Address> servers, String targetGroup)
void	moveServersAndTables(Set<org.apache.hadoop.hbase.net.Address> servers, Set<org.apache.hadoop.hbase.TableName> tables, String targetGroup)
void	moveTables(Set<org.apache.hadoop.hbase.TableName> tables, String targetGroup)
void	removeRSGroup(String name)
void	removeServers(Set<org.apache.hadoop.hbase.net.Address> servers)
void	renameRSGroup(String oldName, String newName)
void	updateConfiguration(String groupName)
void	updateRSGroupConfig(String groupName, Map<String,String> configuration)
void	verify()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.rsgroup.RSGroupAdmin

balanceRSGroup

Field Details

table

private org.apache.hadoop.hbase.client.Table table

zkw

private org.apache.hadoop.hbase.zookeeper.ZKWatcher zkw

wrapped

private org.apache.hadoop.hbase.rsgroup.RSGroupAdmin wrapped

Constructor Details

VerifyingRSGroupAdminClient

public VerifyingRSGroupAdminClient(org.apache.hadoop.hbase.rsgroup.RSGroupAdmin RSGroupAdmin,
 org.apache.hadoop.conf.Configuration conf)
                            throws IOException

Throws:

IOException

Method Details

addRSGroup

public void addRSGroup(String groupName)
                throws IOException

Specified by:

addRSGroup in interface org.apache.hadoop.hbase.rsgroup.RSGroupAdmin

Throws:

IOException

getRSGroupInfo

public org.apache.hadoop.hbase.rsgroup.RSGroupInfo getRSGroupInfo(String groupName)
                                                           throws IOException

Specified by:

getRSGroupInfo in interface org.apache.hadoop.hbase.rsgroup.RSGroupAdmin

Throws:

IOException

getRSGroupInfoOfTable

public org.apache.hadoop.hbase.rsgroup.RSGroupInfo getRSGroupInfoOfTable(org.apache.hadoop.hbase.TableName tableName)
                                                                  throws IOException

Specified by:

getRSGroupInfoOfTable in interface org.apache.hadoop.hbase.rsgroup.RSGroupAdmin

Throws:

IOException

moveServers

public void moveServers(Set<org.apache.hadoop.hbase.net.Address> servers,
 String targetGroup)
                 throws IOException

Specified by:

moveServers in interface org.apache.hadoop.hbase.rsgroup.RSGroupAdmin

Throws:

IOException

moveTables

public void moveTables(Set<org.apache.hadoop.hbase.TableName> tables,
 String targetGroup)
                throws IOException

Specified by:

moveTables in interface org.apache.hadoop.hbase.rsgroup.RSGroupAdmin

Throws:

IOException

removeRSGroup

public void removeRSGroup(String name)
                   throws IOException

Specified by:

removeRSGroup in interface org.apache.hadoop.hbase.rsgroup.RSGroupAdmin

Throws:

IOException

balanceRSGroup

public org.apache.hadoop.hbase.client.BalanceResponse balanceRSGroup(String groupName,
 org.apache.hadoop.hbase.client.BalanceRequest request)
                                                              throws IOException

Specified by:

balanceRSGroup in interface org.apache.hadoop.hbase.rsgroup.RSGroupAdmin

Throws:

IOException

listRSGroups

public List<org.apache.hadoop.hbase.rsgroup.RSGroupInfo> listRSGroups()
                                                               throws IOException

Specified by:

listRSGroups in interface org.apache.hadoop.hbase.rsgroup.RSGroupAdmin

Throws:

IOException

getRSGroupOfServer

public org.apache.hadoop.hbase.rsgroup.RSGroupInfo getRSGroupOfServer(org.apache.hadoop.hbase.net.Address hostPort)
                                                               throws IOException

Specified by:

getRSGroupOfServer in interface org.apache.hadoop.hbase.rsgroup.RSGroupAdmin

Throws:

IOException

moveServersAndTables

public void moveServersAndTables(Set<org.apache.hadoop.hbase.net.Address> servers,
 Set<org.apache.hadoop.hbase.TableName> tables,
 String targetGroup)
                          throws IOException

Specified by:

moveServersAndTables in interface org.apache.hadoop.hbase.rsgroup.RSGroupAdmin

Throws:

IOException

removeServers

public void removeServers(Set<org.apache.hadoop.hbase.net.Address> servers)
                   throws IOException

Specified by:

removeServers in interface org.apache.hadoop.hbase.rsgroup.RSGroupAdmin

Throws:

IOException

renameRSGroup

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

Specified by:

renameRSGroup in interface org.apache.hadoop.hbase.rsgroup.RSGroupAdmin

Throws:

IOException

updateRSGroupConfig

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

Specified by:

updateRSGroupConfig in interface org.apache.hadoop.hbase.rsgroup.RSGroupAdmin

Throws:

IOException

updateConfiguration

public void updateConfiguration(String groupName)
                         throws IOException

Specified by:

updateConfiguration in interface org.apache.hadoop.hbase.rsgroup.RSGroupAdmin

Throws:

IOException

verify

public void verify()
            throws IOException

Throws:

IOException