@InterfaceAudience.Private public interface RSGroupInfoManager
RSGroupBasedLoadBalancer
Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_REASSIGN_WAIT_INTERVAL |
static byte[] |
META_FAMILY_BYTES |
static byte[] |
META_QUALIFIER_BYTES |
static String |
REASSIGN_WAIT_INTERVAL_KEY |
static byte[] |
ROW_KEY |
static TableName |
RSGROUP_TABLE_NAME |
static String |
rsGroupZNode |
Modifier and Type | Method and Description |
---|---|
void |
addRSGroup(RSGroupInfo rsGroupInfo)
Add given RSGroupInfo to existing list of group infos.
|
RSGroupInfo |
determineRSGroupInfoForTable(TableName tableName)
Determine
RSGroupInfo for the given table. |
RSGroupInfo |
getRSGroup(String groupName)
Gets
RSGroupInfo for the given group name. |
RSGroupInfo |
getRSGroupOfServer(Address serverHostPort)
Gets the group info of server.
|
String |
getRSGroupOfTable(TableName tableName)
Get the group membership of a table
|
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)
Remove a region server group.
|
void |
removeServers(Set<Address> servers)
Remove decommissioned servers from rsgroup
|
void |
renameRSGroup(String oldName,
String newName)
Rename RSGroup
|
void |
start() |
void |
updateRSGroupConfig(String groupName,
Map<String,String> configuration)
Update RSGroup configuration
|
static final String REASSIGN_WAIT_INTERVAL_KEY
static final long DEFAULT_REASSIGN_WAIT_INTERVAL
static final TableName RSGROUP_TABLE_NAME
static final String rsGroupZNode
static final byte[] META_FAMILY_BYTES
static final byte[] META_QUALIFIER_BYTES
static final byte[] ROW_KEY
void start()
void addRSGroup(RSGroupInfo rsGroupInfo) throws IOException
IOException
void removeRSGroup(String groupName) throws IOException
IOException
Set<Address> moveServers(Set<Address> servers, String srcGroup, String dstGroup) throws IOException
servers
- list of servers, must be part of the same groupsrcGroup
- groupName being moved fromdstGroup
- groupName being moved toservers
).IOException
RSGroupInfo getRSGroupOfServer(Address serverHostPort) throws IOException
IOException
RSGroupInfo getRSGroup(String groupName) throws IOException
RSGroupInfo
for the given group name.IOException
String getRSGroupOfTable(TableName tableName) throws IOException
IOException
void moveTables(Set<TableName> tableNames, String groupName) throws IOException
tableNames
- set of tables to movegroupName
- name of group of tables to move toIOException
List<RSGroupInfo> listRSGroups() throws IOException
RSGroupInfo
s.IOException
void refresh() throws IOException
IOException
boolean isOnline()
void moveServersAndTables(Set<Address> servers, Set<TableName> tables, String srcGroup, String dstGroup) throws IOException
servers
- list of servers, must be part of the same grouptables
- set of tables to movesrcGroup
- groupName being moved fromdstGroup
- groupName being moved toIOException
void removeServers(Set<Address> servers) throws IOException
servers
- set of servers to removeIOException
void renameRSGroup(String oldName, String newName) throws IOException
oldName
- old rsgroup namenewName
- new rsgroup nameIOException
RSGroupInfo determineRSGroupInfoForTable(TableName tableName) throws IOException
RSGroupInfo
for the given table.tableName
- table nameRSGroupInfo
which table should belong toIOException
void updateRSGroupConfig(String groupName, Map<String,String> configuration) throws IOException
groupName
- the group nameconfiguration
- new configuration of the group name to be setIOException
- if a remote or network exception occursCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.