org.apache.hadoop.hbase.client

Class TestIncrementsFromClientSide

java.lang.Object

org.apache.hadoop.hbase.client.TestIncrementsFromClientSide

Direct Known Subclasses:

TestIncrementFromClientSideWithCoprocessor

public class TestIncrementsFromClientSide
extends Object

Run Increment tests that use the HBase clients; HTable. Test is parameterized to run the slow and fast increment code paths. If fast, in the @before, we do a rolling restart of the single regionserver so that it can pick up the go fast configuration. Doing it this way should be faster than starting/stopping a cluster per test. Test takes a long time because spin up a cluster between each run -- ugh.

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static byte[]	FAMILY
(package private) org.slf4j.Logger	LOG
org.junit.rules.TestName	name
private static byte[]	QUALIFIER
private static byte[]	ROW
protected static int	SLAVES
protected static HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
TestIncrementsFromClientSide()

Method Summary

Modifier and Type	Method and Description
static void	afterClass()
(package private) static void	assertIncrementKey(org.apache.hadoop.hbase.Cell key, byte[] row, byte[] family, byte[] qualifier, long value) Call over to the adjacent class's method of same name.
static void	beforeClass()
static String	filterStringSoTableNameSafe(String str)
void	testBatchIncrementsWithReturnResultFalse()
void	testDuplicateIncrement() Test increment result when there are duplicate rpc request.
void	testIncrement()
void	testIncrementIncrZeroAtFirst()
void	testIncrementingInvalidValue()
void	testIncrementInvalidArguments()
void	testIncrementOnSameColumn()
void	testIncrementOutOfOrder()
void	testIncrementWithCustomTimestamp()
void	testIncrementWithDeletes()

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

final org.slf4j.Logger LOG

TEST_UTIL

protected static final HBaseTestingUtility TEST_UTIL

ROW

private static byte[] ROW

FAMILY

private static byte[] FAMILY

QUALIFIER

private static byte[] QUALIFIER

SLAVES

protected static int SLAVES

name

public org.junit.rules.TestName name

Constructor Detail

TestIncrementsFromClientSide

public TestIncrementsFromClientSide()

Method Detail

beforeClass

public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

public static void afterClass()
                       throws Exception

Throws:

Exception

testDuplicateIncrement

public void testDuplicateIncrement()
                            throws Exception

Test increment result when there are duplicate rpc request.

Throws:

Exception

testIncrementWithDeletes

public void testIncrementWithDeletes()
                              throws Exception

Throws:

Exception

testIncrementingInvalidValue

public void testIncrementingInvalidValue()
                                  throws Exception

Throws:

Exception

testBatchIncrementsWithReturnResultFalse

public void testBatchIncrementsWithReturnResultFalse()
                                              throws Exception

Throws:

Exception

testIncrementInvalidArguments

public void testIncrementInvalidArguments()
                                   throws Exception

Throws:

Exception

testIncrementOutOfOrder

public void testIncrementOutOfOrder()
                             throws Exception

Throws:

Exception

testIncrementOnSameColumn

public void testIncrementOnSameColumn()
                               throws Exception

Throws:

Exception

testIncrementIncrZeroAtFirst

public void testIncrementIncrZeroAtFirst()
                                  throws Exception

Throws:

Exception

testIncrement

public void testIncrement()
                   throws Exception

Throws:

Exception

testIncrementWithCustomTimestamp

public void testIncrementWithCustomTimestamp()
                                      throws IOException

Throws:

IOException

assertIncrementKey

static void assertIncrementKey(org.apache.hadoop.hbase.Cell key,
                               byte[] row,
                               byte[] family,
                               byte[] qualifier,
                               long value)
                        throws Exception

Call over to the adjacent class's method of same name.

Throws:

Exception

filterStringSoTableNameSafe

public static String filterStringSoTableNameSafe(String str)