Package org.apache.hadoop.hbase.quotas
Class ThrottleQuotaTestUtil
java.lang.Object
org.apache.hadoop.hbase.quotas.ThrottleQuotaTestUtil
-
Field Summary
Modifier and TypeFieldDescriptionprivate static org.apache.hadoop.hbase.util.ManualEnvironmentEdge
private static final org.slf4j.Logger
private static final int
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescription(package private) static void
clearQuotaCache
(HBaseTestingUtil 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
(HBaseTestingUtil testUtil) private static void
triggerCacheRefresh
(HBaseTestingUtil testUtil, boolean bypass, boolean userLimiter, boolean tableLimiter, boolean nsLimiter, boolean rsLimiter, boolean exceedThrottleQuota, org.apache.hadoop.hbase.TableName... tables) (package private) static void
triggerExceedThrottleQuotaCacheRefresh
(HBaseTestingUtil testUtil, boolean exceedEnabled) (package private) static void
triggerNamespaceCacheRefresh
(HBaseTestingUtil testUtil, boolean bypass, org.apache.hadoop.hbase.TableName... tables) (package private) static void
triggerRegionServerCacheRefresh
(HBaseTestingUtil testUtil, boolean bypass) (package private) static void
triggerTableCacheRefresh
(HBaseTestingUtil testUtil, boolean bypass, org.apache.hadoop.hbase.TableName... tables) (package private) static void
triggerUserCacheRefresh
(HBaseTestingUtil testUtil, boolean bypass, org.apache.hadoop.hbase.TableName... tables) (package private) static void
-
Field Details
-
LOG
-
envEdge
-
REFRESH_TIME
- See Also:
-
-
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
-
doGets
-
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
-
triggerUserCacheRefresh
static void triggerUserCacheRefresh(HBaseTestingUtil testUtil, boolean bypass, org.apache.hadoop.hbase.TableName... tables) throws Exception - Throws:
Exception
-
triggerTableCacheRefresh
static void triggerTableCacheRefresh(HBaseTestingUtil testUtil, boolean bypass, org.apache.hadoop.hbase.TableName... tables) throws Exception - Throws:
Exception
-
triggerNamespaceCacheRefresh
static void triggerNamespaceCacheRefresh(HBaseTestingUtil testUtil, boolean bypass, org.apache.hadoop.hbase.TableName... tables) throws Exception - Throws:
Exception
-
triggerRegionServerCacheRefresh
static void triggerRegionServerCacheRefresh(HBaseTestingUtil testUtil, boolean bypass) throws Exception - Throws:
Exception
-
triggerExceedThrottleQuotaCacheRefresh
static void triggerExceedThrottleQuotaCacheRefresh(HBaseTestingUtil testUtil, boolean exceedEnabled) throws Exception - Throws:
Exception
-
triggerCacheRefresh
private static void triggerCacheRefresh(HBaseTestingUtil testUtil, boolean bypass, boolean userLimiter, boolean tableLimiter, boolean nsLimiter, boolean rsLimiter, boolean exceedThrottleQuota, org.apache.hadoop.hbase.TableName... tables) throws Exception - Throws:
Exception
-
getQuotaCaches
-
waitMinuteQuota
-
clearQuotaCache
-