Package org.apache.hadoop.hbase.quotas

Class TestDefaultOperationQuota

java.lang.Object

org.apache.hadoop.hbase.quotas.TestDefaultOperationQuota

@Tag("org.apache.hadoop.hbase.testclassification.RegionServerTests") @Tag("org.apache.hadoop.hbase.testclassification.SmallTests")
public class TestDefaultOperationQuota
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.apache.hadoop.conf.Configuration	conf
private static final int	DEFAULT_REQUESTS_PER_SECOND
private static org.apache.hadoop.hbase.util.ManualEnvironmentEdge	envEdge

Constructor Summary

Constructors

Constructor	Description
TestDefaultOperationQuota()

Method Summary

Modifier and Type	Method	Description
void	testLargeBatchSaturatesReadNumLimit()
void	testLargeBatchSaturatesReadWriteLimit()
void	testScanEstimateFlatWorkload()
void	testScanEstimateGrowingWorkload()
void	testScanEstimateNewScanner()
void	testScanEstimateSecondNextCall()
void	testScanEstimateShrinkingWorkload()
void	testScanEstimateVariableFlatWorkload()
void	testTooLargeReadBatchIsNotBlocked()
void	testTooLargeReadSizeIsNotBlocked()
void	testTooLargeRequestSizeIsNotBlocked()
void	testTooLargeWriteBatchIsNotBlocked()
void	testTooLargeWriteSizeIsNotBlocked()

Methods inherited from class java.lang.Object

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

Field Details

conf

private static final org.apache.hadoop.conf.Configuration conf

DEFAULT_REQUESTS_PER_SECOND

private static final int DEFAULT_REQUESTS_PER_SECOND

See Also:

• Constant Field Values

envEdge

private static org.apache.hadoop.hbase.util.ManualEnvironmentEdge envEdge

Constructor Details

TestDefaultOperationQuota

public TestDefaultOperationQuota()

Method Details

testScanEstimateNewScanner

@Test
public void testScanEstimateNewScanner()

testScanEstimateSecondNextCall

@Test
public void testScanEstimateSecondNextCall()

testScanEstimateFlatWorkload

@Test
public void testScanEstimateFlatWorkload()

testScanEstimateVariableFlatWorkload

@Test
public void testScanEstimateVariableFlatWorkload()

testScanEstimateGrowingWorkload

@Test
public void testScanEstimateGrowingWorkload()

testScanEstimateShrinkingWorkload

@Test
public void testScanEstimateShrinkingWorkload()

testLargeBatchSaturatesReadNumLimit

@Test
public void testLargeBatchSaturatesReadNumLimit()
                                         throws org.apache.hadoop.hbase.quotas.RpcThrottlingException,
InterruptedException

Throws:

org.apache.hadoop.hbase.quotas.RpcThrottlingException

InterruptedException

testLargeBatchSaturatesReadWriteLimit

@Test
public void testLargeBatchSaturatesReadWriteLimit()
                                           throws org.apache.hadoop.hbase.quotas.RpcThrottlingException,
InterruptedException

Throws:

org.apache.hadoop.hbase.quotas.RpcThrottlingException

InterruptedException

testTooLargeReadBatchIsNotBlocked

@Test
public void testTooLargeReadBatchIsNotBlocked()
                                       throws org.apache.hadoop.hbase.quotas.RpcThrottlingException,
InterruptedException

Throws:

org.apache.hadoop.hbase.quotas.RpcThrottlingException

InterruptedException

testTooLargeWriteBatchIsNotBlocked

@Test
public void testTooLargeWriteBatchIsNotBlocked()
                                        throws org.apache.hadoop.hbase.quotas.RpcThrottlingException,
InterruptedException

Throws:

org.apache.hadoop.hbase.quotas.RpcThrottlingException

InterruptedException

testTooLargeWriteSizeIsNotBlocked

@Test
public void testTooLargeWriteSizeIsNotBlocked()
                                       throws org.apache.hadoop.hbase.quotas.RpcThrottlingException,
InterruptedException

Throws:

org.apache.hadoop.hbase.quotas.RpcThrottlingException

InterruptedException

testTooLargeReadSizeIsNotBlocked

@Test
public void testTooLargeReadSizeIsNotBlocked()
                                      throws org.apache.hadoop.hbase.quotas.RpcThrottlingException,
InterruptedException

Throws:

org.apache.hadoop.hbase.quotas.RpcThrottlingException

InterruptedException

testTooLargeRequestSizeIsNotBlocked

@Test
public void testTooLargeRequestSizeIsNotBlocked()
                                         throws org.apache.hadoop.hbase.quotas.RpcThrottlingException,
InterruptedException

Throws:

org.apache.hadoop.hbase.quotas.RpcThrottlingException

InterruptedException