Package org.apache.hadoop.hbase.quotas

Class TestAtomicReadQuota

java.lang.Object

org.apache.hadoop.hbase.quotas.TestAtomicReadQuota

public class TestAtomicReadQuota
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static interface	TestAtomicReadQuota.ThrowingFunction<I,O>

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static final byte[]	FAMILY
private static final org.slf4j.Logger	LOG
private static final byte[]	QUALIFIER
private static final org.apache.hadoop.hbase.TableName	TABLE_NAME
private static final HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestAtomicReadQuota()

Method Summary

Modifier and Type	Method	Description
private void	cleanupQuota()
private org.apache.hadoop.hbase.client.Table	getTable()
private void	runNonAtomicPuts()
private void	runNonAtomicReads()
private void	setupAtomicOnlyReadSizeQuota()
private void	setupAtomicOnlyReqNumQuota()
static void	setUpBeforeClass()
private void	setupGenericQuota()
static void	tearDown()
void	testAtomicBatchCountedAgainstAtomicOnlyReadSize()
void	testAtomicBatchCountedAgainstAtomicOnlyReqNum()
void	testAtomicBatchCountedAgainstReadCapacity()
void	testCheckAndMutateCountedAgainstReadCapacity()
void	testConditionalRowMutationsCountedAgainstReadCapacity()
void	testIncrementCountedAgainstReadCapacity()
void	testNonAtomicMultiPutOmittedFromReadCapacity()
void	testNonAtomicPutOmittedFromReadCapacity()
void	testNonAtomicReadsIgnoredByAtomicOnlyReadSize()
void	testNonAtomicReadsIgnoredByAtomicOnlyReqNum()
void	testNonAtomicWritesIgnoredByAtomicOnlyReadSize()
void	testNonAtomicWritesIgnoredByAtomicOnlyReqNum()
void	testNonConditionalRowMutationsOmittedFromReadCapacity()
private void	testThrottle(TestAtomicReadQuota.ThrowingFunction<org.apache.hadoop.hbase.client.Table,?> request)

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

LOG

private static final org.slf4j.Logger LOG

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

TABLE_NAME

private static final org.apache.hadoop.hbase.TableName TABLE_NAME

FAMILY

private static final byte[] FAMILY

QUALIFIER

private static final byte[] QUALIFIER

Constructor Details

TestAtomicReadQuota

public TestAtomicReadQuota()

Method Details

tearDown

public static void tearDown()
                     throws Exception

Throws:

Exception

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

testIncrementCountedAgainstReadCapacity

public void testIncrementCountedAgainstReadCapacity()
                                             throws Exception

Throws:

Exception

testConditionalRowMutationsCountedAgainstReadCapacity

public void testConditionalRowMutationsCountedAgainstReadCapacity()
                                                           throws Exception

Throws:

Exception

testNonConditionalRowMutationsOmittedFromReadCapacity

public void testNonConditionalRowMutationsOmittedFromReadCapacity()
                                                           throws Exception

Throws:

Exception

testNonAtomicPutOmittedFromReadCapacity

public void testNonAtomicPutOmittedFromReadCapacity()
                                             throws Exception

Throws:

Exception

testNonAtomicMultiPutOmittedFromReadCapacity

public void testNonAtomicMultiPutOmittedFromReadCapacity()
                                                  throws Exception

Throws:

Exception

testCheckAndMutateCountedAgainstReadCapacity

public void testCheckAndMutateCountedAgainstReadCapacity()
                                                  throws Exception

Throws:

Exception

testAtomicBatchCountedAgainstReadCapacity

public void testAtomicBatchCountedAgainstReadCapacity()
                                               throws Exception

Throws:

Exception

testAtomicBatchCountedAgainstAtomicOnlyReqNum

public void testAtomicBatchCountedAgainstAtomicOnlyReqNum()
                                                   throws Exception

Throws:

Exception

testAtomicBatchCountedAgainstAtomicOnlyReadSize

public void testAtomicBatchCountedAgainstAtomicOnlyReadSize()
                                                     throws Exception

Throws:

Exception

testNonAtomicWritesIgnoredByAtomicOnlyReqNum

public void testNonAtomicWritesIgnoredByAtomicOnlyReqNum()
                                                  throws Exception

Throws:

Exception

testNonAtomicWritesIgnoredByAtomicOnlyReadSize

public void testNonAtomicWritesIgnoredByAtomicOnlyReadSize()
                                                    throws Exception

Throws:

Exception

testNonAtomicReadsIgnoredByAtomicOnlyReqNum

public void testNonAtomicReadsIgnoredByAtomicOnlyReqNum()
                                                 throws Exception

Throws:

Exception

testNonAtomicReadsIgnoredByAtomicOnlyReadSize

public void testNonAtomicReadsIgnoredByAtomicOnlyReadSize()
                                                   throws Exception

Throws:

Exception

runNonAtomicPuts

private void runNonAtomicPuts()
                       throws Exception

Throws:

Exception

runNonAtomicReads

private void runNonAtomicReads()
                        throws Exception

Throws:

Exception

setupGenericQuota

private void setupGenericQuota()
                        throws Exception

Throws:

Exception

setupAtomicOnlyReqNumQuota

private void setupAtomicOnlyReqNumQuota()
                                 throws Exception

Throws:

Exception

setupAtomicOnlyReadSizeQuota

private void setupAtomicOnlyReadSizeQuota()
                                   throws Exception

Throws:

Exception

cleanupQuota

private void cleanupQuota()
                   throws Exception

Throws:

Exception

testThrottle

private void testThrottle(TestAtomicReadQuota.ThrowingFunction<org.apache.hadoop.hbase.client.Table,?> request)
                   throws Exception

Throws:

Exception

getTable

private org.apache.hadoop.hbase.client.Table getTable()
                                               throws IOException

Throws:

IOException