Package org.apache.hadoop.hbase.rsgroup

Class TestRSGroupsBase

java.lang.Object

org.apache.hadoop.hbase.client.AbstractTestUpdateConfiguration

org.apache.hadoop.hbase.rsgroup.TestRSGroupsBase

Direct Known Subclasses:

TestMigrateRSGroupInfo, TestRSGroupConfig, TestRSGroupsAdmin1, TestRSGroupsAdmin2, TestRSGroupsBalance, TestRSGroupsBasics, TestRSGroupsCPHookCalled, TestRSGroupsFallback, TestRSGroupsKillRS, TestRSGroupsOfflineMode, TestUpdateRSGroupConfiguration

public abstract class TestRSGroupsBase
extends AbstractTestUpdateConfiguration

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestRSGroupsBase.CPMasterObserver
protected static final class	TestRSGroupsBase.MethodName

Field Summary

Fields

Modifier and Type	Field	Description
protected static org.apache.hadoop.hbase.client.Admin	ADMIN
protected static HBaseClusterInterface	CLUSTER
protected static final String	GROUP_PREFIX
protected boolean	INIT
protected static final org.slf4j.Logger	LOG
protected static org.apache.hadoop.hbase.master.HMaster	MASTER
protected final TestRSGroupsBase.MethodName	name
static int	NUM_DEAD_SERVERS
static final int	NUM_SLAVES_BASE
protected static TestRSGroupsBase.CPMasterObserver	OBSERVER
protected static final String	TABLE_PREFIX
protected org.apache.hadoop.hbase.TableName	tableName
protected static HBaseTestingUtil	TEST_UTIL
static final long	WAIT_TIMEOUT

Constructor Summary

Constructors

Constructor	Description
TestRSGroupsBase()

Method Summary

Modifier and Type	Method	Description
protected final org.apache.hadoop.hbase.rsgroup.RSGroupInfo	addGroup(String groupName, int serverCount)
protected final void	deleteGroups()
protected final void	deleteNamespaceIfNecessary()
protected final void	deleteTableIfNecessary()
protected final String	getGroupName(String baseName)
static String	getNameWithoutIndex(String name)
protected int	getNumServers()
protected final org.apache.hadoop.hbase.ServerName	getServerName(org.apache.hadoop.hbase.net.Address addr)	The server name in group does not contain the start code, this method will find out the start code and construct the ServerName object.
protected Map<org.apache.hadoop.hbase.TableName,List<String>>	getTableRegionMap()
protected Map<org.apache.hadoop.hbase.TableName,Map<org.apache.hadoop.hbase.ServerName,List<String>>>	getTableServerRegionMap()
protected static void	initialize()
protected final void	removeGroup(String groupName)
void	setUpBeforeMethod(org.junit.jupiter.api.TestInfo testInfo)
static void	setUpTestBeforeClass()
static void	tearDownAfterClass()
void	tearDownAfterMethod()
protected final void	toggleQuotaCheckAndRestartMiniCluster(boolean enable)

Methods inherited from class org.apache.hadoop.hbase.client.AbstractTestUpdateConfiguration

addResourceToRegionServerConfiguration, replaceHBaseSiteXML, restoreHBaseSiteXML, setUpConfigurationFiles

Methods inherited from class java.lang.Object

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

Field Details

LOG

protected static final org.slf4j.Logger LOG

GROUP_PREFIX

protected static final String GROUP_PREFIX

See Also:

• Constant Field Values

TABLE_PREFIX

protected static final String TABLE_PREFIX

See Also:

• Constant Field Values

TEST_UTIL

protected static HBaseTestingUtil TEST_UTIL

ADMIN

protected static org.apache.hadoop.hbase.client.Admin ADMIN

CLUSTER

protected static HBaseClusterInterface CLUSTER

MASTER

protected static org.apache.hadoop.hbase.master.HMaster MASTER

INIT

protected boolean INIT

OBSERVER

protected static TestRSGroupsBase.CPMasterObserver OBSERVER

WAIT_TIMEOUT

public static final long WAIT_TIMEOUT

See Also:

• Constant Field Values

NUM_SLAVES_BASE

public static final int NUM_SLAVES_BASE

See Also:

• Constant Field Values

NUM_DEAD_SERVERS

public static int NUM_DEAD_SERVERS

name

protected final TestRSGroupsBase.MethodName name

tableName

protected org.apache.hadoop.hbase.TableName tableName

Constructor Details

TestRSGroupsBase

public TestRSGroupsBase()

Method Details

getNameWithoutIndex

public static String getNameWithoutIndex(String name)

setUpTestBeforeClass

public static void setUpTestBeforeClass()
                                 throws Exception

Throws:

Exception

initialize

protected static void initialize()
                          throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setUpBeforeMethod

public void setUpBeforeMethod(org.junit.jupiter.api.TestInfo testInfo)
                       throws Exception

Throws:

Exception

tearDownAfterMethod

public void tearDownAfterMethod()
                         throws Exception

Throws:

Exception

addGroup

protected final org.apache.hadoop.hbase.rsgroup.RSGroupInfo addGroup(String groupName,
 int serverCount)
                                                              throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

removeGroup

protected final void removeGroup(String groupName)
                          throws IOException

Throws:

IOException

deleteTableIfNecessary

protected final void deleteTableIfNecessary()
                                     throws IOException

Throws:

IOException

deleteNamespaceIfNecessary

protected final void deleteNamespaceIfNecessary()
                                         throws IOException

Throws:

IOException

deleteGroups

protected final void deleteGroups()
                           throws IOException

Throws:

IOException

getTableRegionMap

protected Map<org.apache.hadoop.hbase.TableName,List<String>> getTableRegionMap()
                                                                         throws IOException

Throws:

IOException

getTableServerRegionMap

protected Map<org.apache.hadoop.hbase.TableName,Map<org.apache.hadoop.hbase.ServerName,List<String>>> getTableServerRegionMap()
                                                                                                                       throws IOException

Throws:

IOException

getNumServers

protected int getNumServers()
                     throws IOException

Throws:

IOException

getGroupName

protected final String getGroupName(String baseName)

getServerName

protected final org.apache.hadoop.hbase.ServerName getServerName(org.apache.hadoop.hbase.net.Address addr)

The server name in group does not contain the start code, this method will find out the start code and construct the ServerName object.

toggleQuotaCheckAndRestartMiniCluster

protected final void toggleQuotaCheckAndRestartMiniCluster(boolean enable)
                                                    throws Exception

Throws:

Exception