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 HBaseTestingUtility	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()
static void	setUpBeforeClass()
private void	setupQuota()
static void	tearDown()
void	testAtomicBatchCountedAgainstReadCapacity()
void	testCheckAndMutateCountedAgainstReadCapacity()
void	testConditionalRowMutationsCountedAgainstReadCapacity()
void	testIncrementCountedAgainstReadCapacity()
void	testNonAtomicMultiPutOmittedFromReadCapacity()
void	testNonAtomicPutOmittedFromReadCapacity()
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 HBaseTestingUtility 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

setupQuota

private void setupQuota()
                 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