public class TestAtomicReadQuota extends Object
Modifier and Type | Class and Description |
---|---|
private static interface |
TestAtomicReadQuota.ThrowingFunction<I,O> |
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static byte[] |
FAMILY |
private static org.slf4j.Logger |
LOG |
private static byte[] |
QUALIFIER |
private static org.apache.hadoop.hbase.TableName |
TABLE_NAME |
private static HBaseTestingUtil |
TEST_UTIL |
Constructor and Description |
---|
TestAtomicReadQuota() |
Modifier and Type | Method and 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) |
public static final HBaseClassTestRule CLASS_RULE
private static final org.slf4j.Logger LOG
private static final HBaseTestingUtil TEST_UTIL
private static final org.apache.hadoop.hbase.TableName TABLE_NAME
private static final byte[] FAMILY
private static final byte[] QUALIFIER
public TestAtomicReadQuota()
public static void setUpBeforeClass() throws Exception
Exception
public void testIncrementCountedAgainstReadCapacity() throws Exception
Exception
public void testConditionalRowMutationsCountedAgainstReadCapacity() throws Exception
Exception
public void testNonConditionalRowMutationsOmittedFromReadCapacity() throws Exception
Exception
public void testNonAtomicPutOmittedFromReadCapacity() throws Exception
Exception
public void testNonAtomicMultiPutOmittedFromReadCapacity() throws Exception
Exception
public void testCheckAndMutateCountedAgainstReadCapacity() throws Exception
Exception
public void testAtomicBatchCountedAgainstReadCapacity() throws Exception
Exception
private void setupQuota() throws Exception
Exception
private void cleanupQuota() throws Exception
Exception
private void testThrottle(TestAtomicReadQuota.ThrowingFunction<org.apache.hadoop.hbase.client.Table,?> request) throws Exception
Exception
private org.apache.hadoop.hbase.client.Table getTable() throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.