Package org.apache.hadoop.hbase.quotas

Class TestQuotaAdmin

java.lang.Object

org.apache.hadoop.hbase.quotas.TestQuotaAdmin

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
static final HBaseClassTestRule	CLASS_RULE
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 HBaseTestingUtility	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

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

TEST_UTIL

private static final HBaseTestingUtility 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

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

clearQuotaTable

public void clearQuotaTable()
                     throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testThrottleType

public void testThrottleType()
                      throws Exception

Throws:

Exception

testSimpleScan

public void testSimpleScan()
                    throws Exception

Throws:

Exception

testMultiQuotaThrottling

public void testMultiQuotaThrottling()
                              throws Exception

Throws:

Exception

testQuotaRetrieverFilter

public void testQuotaRetrieverFilter()
                              throws Exception

Throws:

Exception

testSetGetRemoveSpaceQuota

public void testSetGetRemoveSpaceQuota()
                                throws Exception

Throws:

Exception

testSetModifyRemoveSpaceQuota

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

public void testSetGetRemoveRPCQuota()
                              throws Exception

Throws:

Exception

testSetGetRemoveRPCQuota

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

Throws:

Exception

testSetModifyRemoveRPCQuota

public void testSetModifyRemoveRPCQuota()
                                 throws Exception

Throws:

Exception

testSetAndRemoveRegionServerQuota

public void testSetAndRemoveRegionServerQuota()
                                       throws Exception

Throws:

Exception

testRpcThrottleWhenStartup

public void testRpcThrottleWhenStartup()
                                throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testSwitchRpcThrottle

public void testSwitchRpcThrottle()
                           throws IOException

Throws:

IOException

testSwitchExceedThrottleQuota

public void testSwitchExceedThrottleQuota()
                                   throws IOException

Throws:

IOException

testQuotaScope

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

public void testUserUnThrottleByType()
                              throws Exception

Throws:

Exception

testUserTableUnThrottleByType

public void testUserTableUnThrottleByType()
                                   throws Exception

Throws:

Exception

testUserNameSpaceUnThrottleByType

public void testUserNameSpaceUnThrottleByType()
                                       throws Exception

Throws:

Exception

testTableUnThrottleByType

public void testTableUnThrottleByType()
                               throws Exception

Throws:

Exception

testNameSpaceUnThrottleByType

public void testNameSpaceUnThrottleByType()
                                   throws Exception

Throws:

Exception

testRegionServerUnThrottleByType

public void testRegionServerUnThrottleByType()
                                      throws Exception

Throws:

Exception

getQuotaSettingCount

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

Throws:

IOException

testQuotaTableDisableAndEnable

public void testQuotaTableDisableAndEnable()
                                    throws Exception

Throws:

Exception