org.apache.hadoop.hbase.coprocessor

Class TestRowProcessorEndpoint

java.lang.Object

org.apache.hadoop.hbase.coprocessor.TestRowProcessorEndpoint

public class TestRowProcessorEndpoint
extends Object

Verifies ProcessEndpoint works. The tested RowProcessor performs two scans and a read-modify-write.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	TestRowProcessorEndpoint.IncrementRunner
static class	TestRowProcessorEndpoint.RowProcessorEndpoint<S extends com.google.protobuf.Message,T extends com.google.protobuf.Message> This class defines two RowProcessors: IncrementCounterProcessor and FriendsOfFriendsProcessor.
(package private) class	TestRowProcessorEndpoint.SwapRowsRunner

Field Summary

Fields

Modifier and Type	Field and Description
private static byte[]	A
private static byte[]	B
private static byte[]	C
static HBaseClassTestRule	CLASS_RULE
private static byte[]	COUNTER
private static byte[]	D
private CountDownLatch	doneSignal
private static byte[]	E
private static int	expectedCounter
private static byte[]	F
private AtomicInteger	failures
private static byte[]	FAM
private static byte[]	G
private static org.slf4j.Logger	LOG
private static AtomicLong	myTimer
private static byte[]	ROW
private static byte[]	ROW2
private static int	row2Size
private static int	rowSize
private CountDownLatch	startSignal
private static boolean	swapped
private static org.apache.hadoop.hbase.client.Table	table
private static org.apache.hadoop.hbase.TableName	TABLE
private static HBaseTestingUtility	util

Constructor Summary

Constructors

Constructor and Description
TestRowProcessorEndpoint()

Method Summary

Modifier and Type	Method and Description
private void	concurrentExec(Runnable task, int numThreads)
private int	incrementCounter(org.apache.hadoop.hbase.client.Table table)
void	prepareTestData()
static void	setupBeforeClass()
(package private) static String	stringifyKvs(Collection<org.apache.hadoop.hbase.Cell> kvs)
private void	swapRows(org.apache.hadoop.hbase.client.Table table)
static void	tearDownAfterClass()
void	testDoubleScan()
void	testMultipleRows()
void	testReadModifyWrite()
void	testTimeout()

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

private static final org.slf4j.Logger LOG

TABLE

private static final org.apache.hadoop.hbase.TableName TABLE

ROW

private static final byte[] ROW

ROW2

private static final byte[] ROW2

FAM

private static final byte[] FAM

A

private static final byte[] A

B

private static final byte[] B

C

private static final byte[] C

D

private static final byte[] D

E

private static final byte[] E

F

private static final byte[] F

G

private static final byte[] G

COUNTER

private static final byte[] COUNTER

myTimer

private static final AtomicLong myTimer

failures

private final AtomicInteger failures

util

private static HBaseTestingUtility util

expectedCounter

private static volatile int expectedCounter

rowSize

private static int rowSize

row2Size

private static int row2Size

table

private static volatile org.apache.hadoop.hbase.client.Table table

swapped

private static volatile boolean swapped

startSignal

private volatile CountDownLatch startSignal

doneSignal

private volatile CountDownLatch doneSignal

Constructor Detail

TestRowProcessorEndpoint

public TestRowProcessorEndpoint()

Method Detail

setupBeforeClass

public static void setupBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

prepareTestData

public void prepareTestData()
                     throws Exception

Throws:

Exception

testDoubleScan

public void testDoubleScan()
                    throws Throwable

Throws:

Throwable

testReadModifyWrite

public void testReadModifyWrite()
                         throws Throwable

Throws:

Throwable

incrementCounter

private int incrementCounter(org.apache.hadoop.hbase.client.Table table)
                      throws Throwable

Throws:

Throwable

concurrentExec

private void concurrentExec(Runnable task,
                            int numThreads)
                     throws Throwable

Throws:

Throwable

testMultipleRows

public void testMultipleRows()
                      throws Throwable

Throws:

Throwable

swapRows

private void swapRows(org.apache.hadoop.hbase.client.Table table)
               throws Throwable

Throws:

Throwable

testTimeout

public void testTimeout()
                 throws Throwable

Throws:

Throwable

stringifyKvs

static String stringifyKvs(Collection<org.apache.hadoop.hbase.Cell> kvs)