Package org.apache.hadoop.hbase.quotas

Class ThrottleQuotaTestUtil

java.lang.Object

org.apache.hadoop.hbase.quotas.ThrottleQuotaTestUtil

@Private
public final class ThrottleQuotaTestUtil
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.hadoop.hbase.util.ManualEnvironmentEdge	envEdge
private static final org.slf4j.Logger	LOG
private static final int	REFRESH_TIME

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ThrottleQuotaTestUtil()

Method Summary

Modifier and Type	Method	Description
(package private) static void	clearQuotaCache(HBaseTestingUtility testUtil)
(package private) static long	doGets(int maxOps, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.client.Table... tables)
(package private) static long	doGets(int maxOps, org.apache.hadoop.hbase.client.Table... tables)
(package private) static long	doMultiGets(int maxOps, int batchSize, int rowCount, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.client.Table... tables)
(package private) static int	doPuts(int maxOps, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.client.Table... tables)
(package private) static int	doPuts(int maxOps, int valueSize, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.client.Table... tables)
(package private) static long	doScans(int desiredRows, org.apache.hadoop.hbase.client.Table table, int caching)
private static byte[]	generateValue(int valueSize)
(package private) static Set<org.apache.hadoop.hbase.quotas.QuotaCache>	getQuotaCaches(HBaseTestingUtility testUtil)
private static void	triggerCacheRefresh(HBaseTestingUtility testUtil, boolean bypass, boolean userLimiter, boolean tableLimiter, boolean nsLimiter, boolean rsLimiter, boolean exceedThrottleQuota, org.apache.hadoop.hbase.TableName... tables)
(package private) static void	triggerExceedThrottleQuotaCacheRefresh(HBaseTestingUtility testUtil, boolean exceedEnabled)
(package private) static void	triggerNamespaceCacheRefresh(HBaseTestingUtility testUtil, boolean bypass, org.apache.hadoop.hbase.TableName... tables)
(package private) static void	triggerRegionServerCacheRefresh(HBaseTestingUtility testUtil, boolean bypass)
(package private) static void	triggerTableCacheRefresh(HBaseTestingUtility testUtil, boolean bypass, org.apache.hadoop.hbase.TableName... tables)
(package private) static void	triggerUserCacheRefresh(HBaseTestingUtility testUtil, boolean bypass, org.apache.hadoop.hbase.TableName... tables)
(package private) static void	waitMinuteQuota()

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

envEdge

private static org.apache.hadoop.hbase.util.ManualEnvironmentEdge envEdge

REFRESH_TIME

private static final int REFRESH_TIME

See Also:

• Constant Field Values

Constructor Details

ThrottleQuotaTestUtil

private ThrottleQuotaTestUtil()

Method Details

doPuts

static int doPuts(int maxOps,
 byte[] family,
 byte[] qualifier,
 org.apache.hadoop.hbase.client.Table... tables)

doPuts

static int doPuts(int maxOps,
 int valueSize,
 byte[] family,
 byte[] qualifier,
 org.apache.hadoop.hbase.client.Table... tables)

generateValue

private static byte[] generateValue(int valueSize)

doGets

static long doGets(int maxOps,
 org.apache.hadoop.hbase.client.Table... tables)

doGets

static long doGets(int maxOps,
 byte[] family,
 byte[] qualifier,
 org.apache.hadoop.hbase.client.Table... tables)

doMultiGets

static long doMultiGets(int maxOps,
 int batchSize,
 int rowCount,
 byte[] family,
 byte[] qualifier,
 org.apache.hadoop.hbase.client.Table... tables)

doScans

static long doScans(int desiredRows,
 org.apache.hadoop.hbase.client.Table table,
 int caching)

triggerUserCacheRefresh

static void triggerUserCacheRefresh(HBaseTestingUtility testUtil,
 boolean bypass,
 org.apache.hadoop.hbase.TableName... tables)
                             throws Exception

Throws:

Exception

triggerTableCacheRefresh

static void triggerTableCacheRefresh(HBaseTestingUtility testUtil,
 boolean bypass,
 org.apache.hadoop.hbase.TableName... tables)
                              throws Exception

Throws:

Exception

triggerNamespaceCacheRefresh

static void triggerNamespaceCacheRefresh(HBaseTestingUtility testUtil,
 boolean bypass,
 org.apache.hadoop.hbase.TableName... tables)
                                  throws Exception

Throws:

Exception

triggerRegionServerCacheRefresh

static void triggerRegionServerCacheRefresh(HBaseTestingUtility testUtil,
 boolean bypass)
                                     throws Exception

Throws:

Exception

triggerExceedThrottleQuotaCacheRefresh

static void triggerExceedThrottleQuotaCacheRefresh(HBaseTestingUtility testUtil,
 boolean exceedEnabled)
                                            throws Exception

Throws:

Exception

triggerCacheRefresh

private static void triggerCacheRefresh(HBaseTestingUtility testUtil,
 boolean bypass,
 boolean userLimiter,
 boolean tableLimiter,
 boolean nsLimiter,
 boolean rsLimiter,
 boolean exceedThrottleQuota,
 org.apache.hadoop.hbase.TableName... tables)
                                 throws Exception

Throws:

Exception

getQuotaCaches

static Set<org.apache.hadoop.hbase.quotas.QuotaCache> getQuotaCaches(HBaseTestingUtility testUtil)

waitMinuteQuota

static void waitMinuteQuota()

clearQuotaCache

static void clearQuotaCache(HBaseTestingUtility testUtil)