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 and Description
static class	TestParallelPut.Putter A thread that makes a few put calls

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
TestParallelPut()

Method Summary

Modifier and Type	Method and 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 Detail

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 Detail

TestParallelPut

public TestParallelPut()

Method Detail

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