Package org.apache.hadoop.hbase.quotas
Class ThrottleQuotaTestUtil
java.lang.Object
org.apache.hadoop.hbase.quotas.ThrottleQuotaTestUtil
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static org.apache.hadoop.hbase.util.ManualEnvironmentEdgeprivate static final org.slf4j.Loggerprivate static final int -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescription(package private) static voidclearQuotaCache(HBaseTestingUtil testUtil) (package private) static longdoGets(int maxOps, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.client.Table... tables) (package private) static longdoGets(int maxOps, org.apache.hadoop.hbase.client.Table... tables) (package private) static longdoIncrements(int maxOps, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.client.Table... tables) (package private) static longdoMultiGets(int maxOps, int batchSize, int rowCount, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.client.Table... tables) (package private) static intdoPuts(int maxOps, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.client.Table... tables) (package private) static intdoPuts(int maxOps, int valueSize, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.client.Table... tables) (package private) static longdoScans(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 voidtriggerCacheRefresh(HBaseTestingUtil testUtil, boolean bypass, boolean userLimiter, boolean tableLimiter, boolean nsLimiter, boolean rsLimiter, boolean exceedThrottleQuota, org.apache.hadoop.hbase.TableName... tables) (package private) static voidtriggerExceedThrottleQuotaCacheRefresh(HBaseTestingUtil testUtil, boolean exceedEnabled) (package private) static voidtriggerNamespaceCacheRefresh(HBaseTestingUtil testUtil, boolean bypass, org.apache.hadoop.hbase.TableName... tables) (package private) static voidtriggerRegionServerCacheRefresh(HBaseTestingUtil testUtil, boolean bypass) (package private) static voidtriggerTableCacheRefresh(HBaseTestingUtil testUtil, boolean bypass, org.apache.hadoop.hbase.TableName... tables) (package private) static voidtriggerUserCacheRefresh(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) -
doIncrements
static long doIncrements(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
-