Package org.apache.hadoop.hbase.quotas

Class TestFeedbackAdaptiveRateLimiter

java.lang.Object

org.apache.hadoop.hbase.quotas.TestFeedbackAdaptiveRateLimiter

@Tag("org.apache.hadoop.hbase.testclassification.RegionServerTests") @Tag("org.apache.hadoop.hbase.testclassification.SmallTests")
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
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

testEdge

private TestFeedbackAdaptiveRateLimiter.ManualEnvironmentEdge testEdge

factory

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

Constructor Details

TestFeedbackAdaptiveRateLimiter

public TestFeedbackAdaptiveRateLimiter()

Method Details

setUp

@BeforeEach
public void setUp()

tearDown

@AfterEach
public void tearDown()

testBasicFunctionality

@Test
public void testBasicFunctionality()

testAdaptiveBackoffIncreases

@Test
public void testAdaptiveBackoffIncreases()

testAdaptiveBackoffDecreases

@Test
public void testAdaptiveBackoffDecreases()

testOversubscriptionIncreasesWithLowUtilization

@Test
public void testOversubscriptionIncreasesWithLowUtilization()

testOversubscriptionDecreasesWithHighUtilization

@Test
public void testOversubscriptionDecreasesWithHighUtilization()

testBackoffMultiplierCapsAtMaximum

@Test
public void testBackoffMultiplierCapsAtMaximum()

testOversubscriptionCapsAtMaximum

@Test
public void testOversubscriptionCapsAtMaximum()

testMultipleRefillIntervals

@Test
public void testMultipleRefillIntervals()

testRefillIntervalAdjustment

@Test
public void testRefillIntervalAdjustment()

testBackoffMultiplierBottomsAtOne

@Test
public void testBackoffMultiplierBottomsAtOne()

testConcurrentAccess

@Test
public void testConcurrentAccess()
                          throws InterruptedException

Throws:

InterruptedException

testOverconsumptionBehavior

@Test
public void testOverconsumptionBehavior()

testOscillatingLoadPattern

@Test
public void testOscillatingLoadPattern()

testUtilizationEmaConvergence

@Test
public void testUtilizationEmaConvergence()