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

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

Field Summary

Fields

Modifier and Type	Field and 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 and Description
VerifyingRSGroupAdminClient(org.apache.hadoop.hbase.rsgroup.RSGroupAdmin RSGroupAdmin, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
void	addRSGroup(String groupName)
boolean	balanceRSGroup(String groupName)
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	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

Field Detail

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 Detail

VerifyingRSGroupAdminClient

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

Throws:

IOException

Method Detail

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 boolean balanceRSGroup(String groupName)
                       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

verify

public void verify()
            throws IOException

Throws:

IOException