Package org.apache.hadoop.hbase.quotas

Class TestFeedbackAdaptiveRateLimiter

java.lang.Object

org.apache.hadoop.hbase.quotas.TestFeedbackAdaptiveRateLimiter

public class TestFeedbackAdaptiveRateLimiter
extends Object

Verify the behavior of the FeedbackAdaptiveRateLimiter including adaptive backoff multipliers and over-subscription functionality.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	TestFeedbackAdaptiveRateLimiter.ManualEnvironmentEdge

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.hbase.quotas.FeedbackAdaptiveRateLimiter.FeedbackAdaptiveRateLimiterFactory	factory
private TestFeedbackAdaptiveRateLimiter.ManualEnvironmentEdge	testEdge

Constructor Summary

Constructors

Constructor	Description
TestFeedbackAdaptiveRateLimiter()

Method Summary

Modifier and Type	Method	Description
void	setUp()
void	tearDown()
void	testAdaptiveBackoffDecreases()
void	testAdaptiveBackoffIncreases()
void	testBackoffMultiplierBottomsAtOne()
void	testBackoffMultiplierCapsAtMaximum()
void	testBasicFunctionality()
void	testConcurrentAccess()
void	testMultipleRefillIntervals()
void	testOscillatingLoadPattern()
void	testOverconsumptionBehavior()
void	testOversubscriptionCapsAtMaximum()
void	testOversubscriptionDecreasesWithHighUtilization()
void	testOversubscriptionIncreasesWithLowUtilization()
void	testRefillIntervalAdjustment()
void	testUtilizationEmaConvergence()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

testEdge

private TestFeedbackAdaptiveRateLimiter.ManualEnvironmentEdge testEdge

factory

private org.apache.hadoop.hbase.quotas.FeedbackAdaptiveRateLimiter.FeedbackAdaptiveRateLimiterFactory factory

Constructor Details

TestFeedbackAdaptiveRateLimiter

public TestFeedbackAdaptiveRateLimiter()

Method Details

setUp

public void setUp()

tearDown

public void tearDown()

testBasicFunctionality

public void testBasicFunctionality()

testAdaptiveBackoffIncreases

public void testAdaptiveBackoffIncreases()

testAdaptiveBackoffDecreases

public void testAdaptiveBackoffDecreases()

testOversubscriptionIncreasesWithLowUtilization

public void testOversubscriptionIncreasesWithLowUtilization()

testOversubscriptionDecreasesWithHighUtilization

public void testOversubscriptionDecreasesWithHighUtilization()

testBackoffMultiplierCapsAtMaximum

public void testBackoffMultiplierCapsAtMaximum()

testOversubscriptionCapsAtMaximum

public void testOversubscriptionCapsAtMaximum()

testMultipleRefillIntervals

public void testMultipleRefillIntervals()

testRefillIntervalAdjustment

public void testRefillIntervalAdjustment()

testBackoffMultiplierBottomsAtOne

public void testBackoffMultiplierBottomsAtOne()

testConcurrentAccess

public void testConcurrentAccess()
                          throws InterruptedException

Throws:

InterruptedException

testOverconsumptionBehavior

public void testOverconsumptionBehavior()

testOscillatingLoadPattern

public void testOscillatingLoadPattern()

testUtilizationEmaConvergence

public void testUtilizationEmaConvergence()