org.apache.hadoop.hbase.coprocessor.example

Class WriteHeavyIncrementObserverTestBase

java.lang.Object

org.apache.hadoop.hbase.coprocessor.example.WriteHeavyIncrementObserverTestBase

Direct Known Subclasses:

TestWriteHeavyIncrementObserver, TestWriteHeavyIncrementObserverWithMemStoreCompaction

public class WriteHeavyIncrementObserverTestBase
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected static byte[]	CQ1
protected static byte[]	CQ2
protected static byte[]	FAMILY
protected static org.apache.hadoop.hbase.TableName	NAME
protected static byte[]	ROW
protected static org.apache.hadoop.hbase.client.Table	TABLE
protected static int	THREADS
protected static long	UPPER
protected static HBaseTestingUtility	UTIL

Constructor Summary

Constructors

Constructor and Description
WriteHeavyIncrementObserverTestBase()

Method Summary

Modifier and Type	Method and Description
protected void	assertSum()
protected void	doIncrement(int sleepSteps)
private static void	increment(int sleepSteps)
static void	setUp()
static void	tearDown()

Methods inherited from class java.lang.Object

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

Field Detail

UTIL

protected static final HBaseTestingUtility UTIL

NAME

protected static org.apache.hadoop.hbase.TableName NAME

FAMILY

protected static byte[] FAMILY

ROW

protected static byte[] ROW

CQ1

protected static byte[] CQ1

CQ2

protected static byte[] CQ2

TABLE

protected static org.apache.hadoop.hbase.client.Table TABLE

UPPER

protected static long UPPER

THREADS

protected static int THREADS

Constructor Detail

WriteHeavyIncrementObserverTestBase

public WriteHeavyIncrementObserverTestBase()

Method Detail

setUp

public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

public static void tearDown()
                     throws Exception

Throws:

Exception

increment

private static void increment(int sleepSteps)
                       throws IOException

Throws:

IOException

assertSum

protected final void assertSum()
                        throws IOException

Throws:

IOException

doIncrement

protected final void doIncrement(int sleepSteps)
                          throws InterruptedException

Throws:

InterruptedException