Package org.apache.hadoop.hbase.regionserver

Class TestParallelPut

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestParallelPut

public class TestParallelPut
extends Object

Testing of multiPut in parallel.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestParallelPut.Putter	A thread that makes a few put calls

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static HBaseTestingUtility	HBTU
private static final org.slf4j.Logger	LOG
org.junit.rules.TestName	name
(package private) static final byte[]	qual1
(package private) static final byte[]	qual2
(package private) static final byte[]	qual3
private org.apache.hadoop.hbase.regionserver.HRegion	region
(package private) static final byte[]	row
(package private) static final byte[]	row2
(package private) static byte[]	tableName
private static final int	THREADS100
(package private) static final byte[]	value1
(package private) static final byte[]	value2

Constructor Summary

Constructors

Constructor	Description
TestParallelPut()

Method Summary

Modifier and Type	Method	Description
private static void	assertGet(org.apache.hadoop.hbase.regionserver.HRegion region, byte[] row, byte[] familiy, byte[] qualifier, byte[] value)
static void	beforeClass()
String	getName()
private org.apache.hadoop.hbase.regionserver.HRegion	initHRegion(byte[] tableName, String callingMethod, byte[]... families)
void	setUp()
void	tearDown()
void	testParallelPuts()	Test multi-threaded Puts.
void	testPut()	Test one put command.

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

name

public org.junit.rules.TestName name

region

private org.apache.hadoop.hbase.regionserver.HRegion region

HBTU

private static HBaseTestingUtility HBTU

THREADS100

private static final int THREADS100

See Also:

• Constant Field Values

tableName

static byte[] tableName

qual1

static final byte[] qual1

qual2

static final byte[] qual2

qual3

static final byte[] qual3

value1

static final byte[] value1

value2

static final byte[] value2

row

static final byte[] row

row2

static final byte[] row2

Constructor Details

TestParallelPut

public TestParallelPut()

Method Details

beforeClass

public static void beforeClass()

setUp

public void setUp()
           throws Exception

Throws:

Exception

See Also:

• HBaseTestCase.setUp()

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

getName

public String getName()

testPut

public void testPut()
             throws IOException

Test one put command.

Throws:

IOException

testParallelPuts

public void testParallelPuts()
                      throws IOException

Test multi-threaded Puts.

Throws:

IOException

assertGet

private static void assertGet(org.apache.hadoop.hbase.regionserver.HRegion region,
 byte[] row,
 byte[] familiy,
 byte[] qualifier,
 byte[] value)
                       throws IOException

Throws:

IOException

initHRegion

private org.apache.hadoop.hbase.regionserver.HRegion initHRegion(byte[] tableName,
 String callingMethod,
 byte[]... families)
                                                          throws IOException

Throws:

IOException