Field Detail

• 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 Detail

• 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