RSGroupInfoManagerImpl (Apache HBase 1.4.11 API)

java.lang.Object
- org.apache.hadoop.hbase.rsgroup.RSGroupInfoManagerImpl

All Implemented Interfaces:

ServerListener, RSGroupInfoManager
```
public class RSGroupInfoManagerImpl
extends Object
implements RSGroupInfoManager, ServerListener
```
This is an implementation of RSGroupInfoManager. Which makes use of an HBase table as the persistence store for the group information. It also makes use of zookeeper to store group information needed for bootstrapping during offline mode.

Field Summary
- Fields inherited from interface org.apache.hadoop.hbase.rsgroup.RSGroupInfoManager
  DEFAULT_REASSIGN_WAIT_INTERVAL, META_FAMILY_BYTES, META_QUALIFIER_BYTES, REASSIGN_WAIT_INTERVAL_KEY, ROW_KEY, RSGROUP_TABLE_NAME, rsGroupZNode

Constructor Summary

Constructors
Constructor and Description

RSGroupInfoManagerImpl(MasterServices master)

Constructors
Constructor and Description
`RSGroupInfoManagerImpl(MasterServices master)`

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`addRSGroup(RSGroupInfo rsGroupInfo)` Adds the group.
`RSGroupInfo`	`getRSGroup(String groupName)` Gets the group information.
`RSGroupInfo`	`getRSGroupOfServer(Address server)` Gets the group info of server.
`String`	`getRSGroupOfTable(TableName tableName)` Gets the group name for a given table
`void`	`init()`
`boolean`	`isOnline()` Whether the manager is able to fully return group metadata
`List<RSGroupInfo>`	`listRSGroups()` List the existing `RSGroupInfo`s.
`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)` Delete a region server group.
`void`	`removeServers(Set<Address> servers)` Remove decommissioned servers from rsgroup
`void`	`serverAdded(ServerName serverName)` The server has joined the cluster.
`void`	`serverRemoved(ServerName serverName)` The server was removed from the cluster.
`void`	`start()`
`void`	`waiting()` Started waiting on RegionServers to check-in.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - RSGroupInfoManagerImpl
```
public RSGroupInfoManagerImpl(MasterServices master)
                       throws IOException
```
    Throws:
    
    IOException
- Method Detail
  - init
```
public void init()
          throws IOException
```
    Throws:
    
    IOException
  - start
```
public void start()
```
    Specified by:
    
    start in interface RSGroupInfoManager
  - addRSGroup
```
public void addRSGroup(RSGroupInfo rsGroupInfo)
                throws IOException
```
    Adds the group.
    
    Specified by:
    
    addRSGroup in interface RSGroupInfoManager
    
    Parameters:
    rsGroupInfo - the group name
    
    Throws:
    
    IOException
  - moveServers
```
public Set<Address> moveServers(Set<Address> servers,
                       String srcGroup,
                       String dstGroup)
                         throws IOException
```
    Description copied from interface: RSGroupInfoManager
    
    Move servers to a new group.
    
    Specified by:
    
    moveServers in interface RSGroupInfoManager
    
    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
```
public RSGroupInfo getRSGroupOfServer(Address server)
                               throws IOException
```
    Gets the group info of server.
    
    Specified by:
    
    getRSGroupOfServer in interface RSGroupInfoManager
    
    Parameters:
    server - the server
    
    Returns:
    An instance of GroupInfo.
    
    Throws:
    
    IOException
  - getRSGroup
```
public RSGroupInfo getRSGroup(String groupName)
                       throws IOException
```
    Gets the group information.
    
    Specified by:
    
    getRSGroup in interface RSGroupInfoManager
    
    Parameters:
    groupName - the group name
    
    Returns:
    An instance of GroupInfo
    
    Throws:
    
    IOException
  - getRSGroupOfTable
```
public String getRSGroupOfTable(TableName tableName)
                         throws IOException
```
    Gets the group name for a given table
    
    Specified by:
    
    getRSGroupOfTable in interface RSGroupInfoManager
    
    Parameters:
    tableName - the table name
    
    Returns:
    group name, or null if not found
    
    Throws:
    
    IOException
  - moveTables
```
public void moveTables(Set<TableName> tableNames,
              String groupName)
                throws IOException
```
    Description copied from interface: RSGroupInfoManager
    
    Set the group membership of a set of tables
    
    Specified by:
    
    moveTables in interface RSGroupInfoManager
    
    Parameters:
    tableNames - set of tables to move
    groupName - name of group of tables to move to
    
    Throws:
    
    IOException
  - removeRSGroup
```
public void removeRSGroup(String groupName)
                   throws IOException
```
    Delete a region server group.
    
    Specified by:
    
    removeRSGroup in interface RSGroupInfoManager
    
    Parameters:
    groupName - the group name
    
    Throws:
    
    IOException - Signals that an I/O exception has occurred.
  - 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
  - refresh
```
public void refresh()
             throws IOException
```
    Description copied from interface: RSGroupInfoManager
    
    Refresh/reload the group information from the persistent store
    
    Specified by:
    
    refresh in interface RSGroupInfoManager
    
    Throws:
    
    IOException
  - serverAdded
```
public void serverAdded(ServerName serverName)
```
    Description copied from interface: ServerListener
    
    The server has joined the cluster.
    
    Specified by:
    
    serverAdded in interface ServerListener
    
    Parameters:
    serverName - The remote servers name.
  - serverRemoved
```
public void serverRemoved(ServerName serverName)
```
    Description copied from interface: ServerListener
    
    The server was removed from the cluster.
    
    Specified by:
    
    serverRemoved in interface ServerListener
    
    Parameters:
    serverName - The remote servers name.
  - waiting
```
public void waiting()
```
    Description copied from interface: ServerListener
    
    Started waiting on RegionServers to check-in.
    
    Specified by:
    
    waiting in interface ServerListener
  - moveServersAndTables
```
public void moveServersAndTables(Set<Address> servers,
                        Set<TableName> tables,
                        String srcGroup,
                        String dstGroup)
                          throws IOException
```
    Description copied from interface: RSGroupInfoManager
    
    Move servers and tables to a new group.
    
    Specified by:
    
    moveServersAndTables in interface RSGroupInfoManager
    
    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
```
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

Class RSGroupInfoManagerImpl

Field Summary

Fields inherited from interface org.apache.hadoop.hbase.rsgroup.RSGroupInfoManager

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

RSGroupInfoManagerImpl

Method Detail

init

start

addRSGroup

moveServers

getRSGroupOfServer

getRSGroup

getRSGroupOfTable

moveTables

removeRSGroup

listRSGroups

isOnline

refresh

serverAdded

serverRemoved

waiting

moveServersAndTables

removeServers