@InterfaceAudience.Private public final class ThrottleQuotaTestUtil extends Object
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 |
Modifier | Constructor and Description |
---|---|
private |
ThrottleQuotaTestUtil() |
Modifier and Type | Method and Description |
---|---|
(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 |
waitMinuteQuota() |
private static final org.slf4j.Logger LOG
private static org.apache.hadoop.hbase.util.ManualEnvironmentEdge envEdge
private static final int REFRESH_TIME
private ThrottleQuotaTestUtil()
static int doPuts(int maxOps, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.client.Table... tables)
static int doPuts(int maxOps, int valueSize, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.client.Table... tables)
private static byte[] generateValue(int valueSize)
static long doGets(int maxOps, org.apache.hadoop.hbase.client.Table... tables)
static long doGets(int maxOps, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.client.Table... tables)
static long doMultiGets(int maxOps, int batchSize, int rowCount, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.client.Table... tables)
static long doScans(int desiredRows, org.apache.hadoop.hbase.client.Table table, int caching)
static void triggerUserCacheRefresh(HBaseTestingUtil testUtil, boolean bypass, org.apache.hadoop.hbase.TableName... tables) throws Exception
Exception
static void triggerTableCacheRefresh(HBaseTestingUtil testUtil, boolean bypass, org.apache.hadoop.hbase.TableName... tables) throws Exception
Exception
static void triggerNamespaceCacheRefresh(HBaseTestingUtil testUtil, boolean bypass, org.apache.hadoop.hbase.TableName... tables) throws Exception
Exception
static void triggerRegionServerCacheRefresh(HBaseTestingUtil testUtil, boolean bypass) throws Exception
Exception
static void triggerExceedThrottleQuotaCacheRefresh(HBaseTestingUtil testUtil, boolean exceedEnabled) throws Exception
Exception
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
Exception
static Set<org.apache.hadoop.hbase.quotas.QuotaCache> getQuotaCaches(HBaseTestingUtil testUtil)
static void waitMinuteQuota()
static void clearQuotaCache(HBaseTestingUtil testUtil)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.