Package 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	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 final HBaseTestingUtil	UTIL

Constructor Summary

Constructors

Constructor	Description
WriteHeavyIncrementObserverTestBase()

Method Summary

Modifier and Type	Method	Description
protected final void	assertSum()
protected final 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 Details

UTIL

protected static final HBaseTestingUtil 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 Details

WriteHeavyIncrementObserverTestBase

public WriteHeavyIncrementObserverTestBase()

Method Details

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