org.apache.hadoop.hbase.quotas

Class ThrottleQuotaTestUtil

java.lang.Object

org.apache.hadoop.hbase.quotas.ThrottleQuotaTestUtil

@InterfaceAudience.Private
public final class ThrottleQuotaTestUtil
extends Object

Field Summary

Fields

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

Constructor Summary

Constructors

Modifier	Constructor and Description
private	ThrottleQuotaTestUtil()

Method Summary

Modifier and Type	Method and Description
(package private) static void	clearQuotaCache(HBaseTestingUtility testUtil)
(package private) static long	doGets(int maxOps, 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)
private static byte[]	generateValue(int valueSize)
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 Detail

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 Detail

ThrottleQuotaTestUtil

private ThrottleQuotaTestUtil()

Method Detail

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)

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

waitMinuteQuota

static void waitMinuteQuota()

clearQuotaCache

static void clearQuotaCache(HBaseTestingUtility testUtil)