Package org.apache.hadoop.hbase.regionserver

Class TestParallelPut

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestParallelPut

@Tag("org.apache.hadoop.hbase.testclassification.RegionServerTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
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
private static HBaseTestingUtil	HBTU
private static final org.slf4j.Logger	LOG
private String	methodName
(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	getMethodName()
private org.apache.hadoop.hbase.regionserver.HRegion	initHRegion(byte[] tableName, String callingMethod, byte[]... families)
void	setUp(org.junit.jupiter.api.TestInfo testInfo)
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

LOG

private static final org.slf4j.Logger LOG

region

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

HBTU

private static HBaseTestingUtil HBTU

THREADS100

private static final int THREADS100

See Also:

• Constant Field Values

methodName

private String methodName

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

@BeforeAll
public static void beforeClass()

setUp

@BeforeEach
public void setUp(org.junit.jupiter.api.TestInfo testInfo)
           throws Exception

Throws:

Exception

tearDown

@AfterEach
public void tearDown()
              throws Exception

Throws:

Exception

getMethodName

public String getMethodName()

testPut

@Test
public void testPut()
             throws IOException

Test one put command.

Throws:

IOException

testParallelPuts

@Test
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