Package org.apache.hadoop.hbase.quotas

Class TestQuotaAdmin

java.lang.Object

org.apache.hadoop.hbase.quotas.TestQuotaAdmin

@Tag("org.apache.hadoop.hbase.testclassification.ClientTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestQuotaAdmin
extends Object

minicluster tests that validate that quota entries are properly set in the quota table

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private static final String[]	NAMESPACES
private static final org.apache.hadoop.hbase.TableName[]	TABLE_NAMES
private static final HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestQuotaAdmin()

Method Summary

Modifier and Type	Method	Description
private void	assertNumResults(int expected, org.apache.hadoop.hbase.quotas.QuotaFilter filter)
private void	assertRPCQuota(org.apache.hadoop.hbase.quotas.ThrottleType type, long limit, TimeUnit tu, org.apache.hadoop.hbase.quotas.QuotaScope scope, org.apache.hadoop.hbase.Cell cell)
private void	assertRPCQuota(org.apache.hadoop.hbase.quotas.ThrottleType type, long limit, TimeUnit tu, org.apache.hadoop.hbase.quotas.QuotaSettings actualSettings)
private void	assertSpaceQuota(long sizeLimit, org.apache.hadoop.hbase.quotas.SpaceViolationPolicy violationPolicy, org.apache.hadoop.hbase.Cell cell)
private void	assertSpaceQuota(long sizeLimit, org.apache.hadoop.hbase.quotas.SpaceViolationPolicy violationPolicy, org.apache.hadoop.hbase.quotas.QuotaSettings actualSettings)
void	clearQuotaTable()
private int	countResults(org.apache.hadoop.hbase.quotas.QuotaFilter filter)
int	getQuotaSettingCount(org.apache.hadoop.hbase.client.Admin admin)
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testMultiQuotaThrottling()
void	testNameSpaceUnThrottleByType()
void	testQuotaRetrieverFilter()
void	testQuotaScope()
void	testQuotaTableDisableAndEnable()
void	testRegionServerUnThrottleByType()
void	testRpcThrottleWhenStartup()
void	testSetAndRemoveRegionServerQuota()
void	testSetGetRemoveRPCQuota()
private void	testSetGetRemoveRPCQuota(org.apache.hadoop.hbase.quotas.ThrottleType throttleType)
void	testSetGetRemoveSpaceQuota()
void	testSetModifyRemoveRPCQuota()
void	testSetModifyRemoveSpaceQuota()
void	testSimpleScan()
void	testSwitchExceedThrottleQuota()
void	testSwitchRpcThrottle()
private void	testSwitchRpcThrottle(org.apache.hadoop.hbase.client.Admin admin, boolean oldRpcThrottle, boolean newRpcThrottle)
void	testTableUnThrottleByType()
void	testThrottleType()
void	testUserNameSpaceUnThrottleByType()
void	testUserTableUnThrottleByType()
void	testUserUnThrottleByType()
private void	verifyFetchableViaAPI(org.apache.hadoop.hbase.client.Admin admin, org.apache.hadoop.hbase.quotas.ThrottleType type, long limit, TimeUnit tu)
private void	verifyNotFetchableViaAPI(org.apache.hadoop.hbase.client.Admin admin)
private void	verifyRecordNotPresentInQuotaTable()
private void	verifyRecordPresentInQuotaTable(org.apache.hadoop.hbase.quotas.ThrottleType type, long limit, TimeUnit tu)
private void	verifyRecordPresentInQuotaTable(org.apache.hadoop.hbase.quotas.ThrottleType type, long limit, TimeUnit tu, org.apache.hadoop.hbase.quotas.QuotaScope scope)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

TABLE_NAMES

private static final org.apache.hadoop.hbase.TableName[] TABLE_NAMES

NAMESPACES

private static final String[] NAMESPACES

Constructor Details

TestQuotaAdmin

public TestQuotaAdmin()

Method Details

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

clearQuotaTable

@AfterEach
public void clearQuotaTable()
                     throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testThrottleType

@Test
public void testThrottleType()
                      throws Exception

Throws:

Exception

testSimpleScan

@Test
public void testSimpleScan()
                    throws Exception

Throws:

Exception

testMultiQuotaThrottling

@Test
public void testMultiQuotaThrottling()
                              throws Exception

Throws:

Exception

testQuotaRetrieverFilter

@Test
public void testQuotaRetrieverFilter()
                              throws Exception

Throws:

Exception

testSetGetRemoveSpaceQuota

@Test
public void testSetGetRemoveSpaceQuota()
                                throws Exception

Throws:

Exception

testSetModifyRemoveSpaceQuota

@Test
public void testSetModifyRemoveSpaceQuota()
                                   throws Exception

Throws:

Exception

assertNumResults

private void assertNumResults(int expected,
 org.apache.hadoop.hbase.quotas.QuotaFilter filter)
                       throws Exception

Throws:

Exception

testSetGetRemoveRPCQuota

@Test
public void testSetGetRemoveRPCQuota()
                              throws Exception

Throws:

Exception

testSetGetRemoveRPCQuota

private void testSetGetRemoveRPCQuota(org.apache.hadoop.hbase.quotas.ThrottleType throttleType)
                               throws Exception

Throws:

Exception

testSetModifyRemoveRPCQuota

@Test
public void testSetModifyRemoveRPCQuota()
                                 throws Exception

Throws:

Exception

testSetAndRemoveRegionServerQuota

@Test
public void testSetAndRemoveRegionServerQuota()
                                       throws Exception

Throws:

Exception

testRpcThrottleWhenStartup

@Test
public void testRpcThrottleWhenStartup()
                                throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testSwitchRpcThrottle

@Test
public void testSwitchRpcThrottle()
                           throws IOException

Throws:

IOException

testSwitchExceedThrottleQuota

@Test
public void testSwitchExceedThrottleQuota()
                                   throws IOException

Throws:

IOException

testQuotaScope

@Test
public void testQuotaScope()
                    throws Exception

Throws:

Exception

testSwitchRpcThrottle

private void testSwitchRpcThrottle(org.apache.hadoop.hbase.client.Admin admin,
 boolean oldRpcThrottle,
 boolean newRpcThrottle)
                            throws IOException

Throws:

IOException

verifyRecordPresentInQuotaTable

private void verifyRecordPresentInQuotaTable(org.apache.hadoop.hbase.quotas.ThrottleType type,
 long limit,
 TimeUnit tu)
                                      throws Exception

Throws:

Exception

verifyRecordPresentInQuotaTable

private void verifyRecordPresentInQuotaTable(org.apache.hadoop.hbase.quotas.ThrottleType type,
 long limit,
 TimeUnit tu,
 org.apache.hadoop.hbase.quotas.QuotaScope scope)
                                      throws Exception

Throws:

Exception

verifyRecordNotPresentInQuotaTable

private void verifyRecordNotPresentInQuotaTable()
                                         throws Exception

Throws:

Exception

verifyFetchableViaAPI

private void verifyFetchableViaAPI(org.apache.hadoop.hbase.client.Admin admin,
 org.apache.hadoop.hbase.quotas.ThrottleType type,
 long limit,
 TimeUnit tu)
                            throws Exception

Throws:

Exception

verifyNotFetchableViaAPI

private void verifyNotFetchableViaAPI(org.apache.hadoop.hbase.client.Admin admin)
                               throws Exception

Throws:

Exception

assertRPCQuota

private void assertRPCQuota(org.apache.hadoop.hbase.quotas.ThrottleType type,
 long limit,
 TimeUnit tu,
 org.apache.hadoop.hbase.quotas.QuotaScope scope,
 org.apache.hadoop.hbase.Cell cell)
                     throws Exception

Throws:

Exception

assertRPCQuota

private void assertRPCQuota(org.apache.hadoop.hbase.quotas.ThrottleType type,
 long limit,
 TimeUnit tu,
 org.apache.hadoop.hbase.quotas.QuotaSettings actualSettings)
                     throws Exception

Throws:

Exception

assertSpaceQuota

private void assertSpaceQuota(long sizeLimit,
 org.apache.hadoop.hbase.quotas.SpaceViolationPolicy violationPolicy,
 org.apache.hadoop.hbase.Cell cell)
                       throws Exception

Throws:

Exception

assertSpaceQuota

private void assertSpaceQuota(long sizeLimit,
 org.apache.hadoop.hbase.quotas.SpaceViolationPolicy violationPolicy,
 org.apache.hadoop.hbase.quotas.QuotaSettings actualSettings)

countResults

private int countResults(org.apache.hadoop.hbase.quotas.QuotaFilter filter)
                  throws Exception

Throws:

Exception

testUserUnThrottleByType

@Test
public void testUserUnThrottleByType()
                              throws Exception

Throws:

Exception

testUserTableUnThrottleByType

@Test
public void testUserTableUnThrottleByType()
                                   throws Exception

Throws:

Exception

testUserNameSpaceUnThrottleByType

@Test
public void testUserNameSpaceUnThrottleByType()
                                       throws Exception

Throws:

Exception

testTableUnThrottleByType

@Test
public void testTableUnThrottleByType()
                               throws Exception

Throws:

Exception

testNameSpaceUnThrottleByType

@Test
public void testNameSpaceUnThrottleByType()
                                   throws Exception

Throws:

Exception

testRegionServerUnThrottleByType

@Test
public void testRegionServerUnThrottleByType()
                                      throws Exception

Throws:

Exception

getQuotaSettingCount

public int getQuotaSettingCount(org.apache.hadoop.hbase.client.Admin admin)
                         throws IOException

Throws:

IOException

testQuotaTableDisableAndEnable

@Test
public void testQuotaTableDisableAndEnable()
                                    throws Exception

Throws:

Exception