Package org.apache.hadoop.hbase.client

Class TestMultiParallel

java.lang.Object

org.apache.hadoop.hbase.client.TestMultiParallel

@Tag("org.apache.hadoop.hbase.testclassification.MediumTests") @Tag("org.apache.hadoop.hbase.testclassification.FlakeyTests")
public class TestMultiParallel
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestMultiParallel.MyMasterObserver

Field Summary

Fields

Modifier and Type	Field	Description
private static final byte[]	BYTES_FAMILY
private static org.apache.hadoop.hbase.client.Connection	CONNECTION
private static final String	FAMILY
private static final byte[][]	KEYS
private static final org.slf4j.Logger	LOG
private static final byte[]	ONE_ROW
private static final byte[]	QUALIFIER
private static final int	slaves
private static final org.apache.hadoop.hbase.TableName	TEST_TABLE
private static final HBaseTestingUtil	UTIL
private static final byte[]	VALUE

Constructor Summary

Constructors

Constructor	Description
TestMultiParallel()

Method Summary

Modifier and Type	Method	Description
static void	afterClass()
void	before()
static void	beforeClass()
private List<org.apache.hadoop.hbase.client.Put>	constructPutRequests()
private void	doTestFlushCommits(boolean doAbort)	Set table auto flush to false and test flushing commits
private static byte[][]	makeKeys()
void	testBadFam()
void	testBatchWithDelete()
void	testBatchWithGet()
void	testBatchWithIncrementAndAppend()
void	testBatchWithManyColsInOneRowGetAndPut()
void	testBatchWithMixedActions()
void	testBatchWithPut()
void	testFlushCommitsNoAbort()
void	testFlushCommitsWithAbort()	Only run one Multi test with a forced RegionServer abort.
void	testHTableDeleteWithList()
private void	validateEmpty(Object r1)
private void	validateLoadedData(org.apache.hadoop.hbase.client.Table table)
private void	validateResult(Object r)
private void	validateResult(Object r1, byte[] qual, byte[] val)
private void	validateSizeAndEmpty(Object[] results, int expectedSize)

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

UTIL

private static final HBaseTestingUtil UTIL

VALUE

private static final byte[] VALUE

QUALIFIER

private static final byte[] QUALIFIER

FAMILY

private static final String FAMILY

See Also:

• Constant Field Values

TEST_TABLE

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

BYTES_FAMILY

private static final byte[] BYTES_FAMILY

ONE_ROW

private static final byte[] ONE_ROW

KEYS

private static final byte[][] KEYS

slaves

private static final int slaves

See Also:

• Constant Field Values

CONNECTION

private static org.apache.hadoop.hbase.client.Connection CONNECTION

Constructor Details

TestMultiParallel

public TestMultiParallel()

Method Details

beforeClass

@BeforeAll
public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

@AfterAll
public static void afterClass()
                       throws Exception

Throws:

Exception

before

@BeforeEach
public void before()
            throws Exception

Throws:

Exception

makeKeys

private static byte[][] makeKeys()

testBatchWithGet

@Test
public void testBatchWithGet()
                      throws Exception

Throws:

Exception

testBadFam

@Test
public void testBadFam()
                throws Exception

Throws:

Exception

testFlushCommitsNoAbort

@Test
public void testFlushCommitsNoAbort()
                             throws Exception

Throws:

Exception

testFlushCommitsWithAbort

@Test
public void testFlushCommitsWithAbort()
                               throws Exception

Only run one Multi test with a forced RegionServer abort. Otherwise, the unit tests will take an unnecessarily long time to run.

Throws:

Exception

doTestFlushCommits

private void doTestFlushCommits(boolean doAbort)
                         throws Exception

Set table auto flush to false and test flushing commits

Parameters:

doAbort - true if abort one regionserver in the testing

Throws:

Exception

testBatchWithPut

@Test
public void testBatchWithPut()
                      throws Exception

Throws:

Exception

testBatchWithDelete

@Test
public void testBatchWithDelete()
                         throws Exception

Throws:

Exception

testHTableDeleteWithList

@Test
public void testHTableDeleteWithList()
                              throws Exception

Throws:

Exception

testBatchWithManyColsInOneRowGetAndPut

@Test
public void testBatchWithManyColsInOneRowGetAndPut()
                                            throws Exception

Throws:

Exception

testBatchWithIncrementAndAppend

@Test
public void testBatchWithIncrementAndAppend()
                                     throws Exception

Throws:

Exception

testBatchWithMixedActions

@Test
public void testBatchWithMixedActions()
                               throws Exception

Throws:

Exception

validateResult

private void validateResult(Object r)

validateResult

private void validateResult(Object r1,
 byte[] qual,
 byte[] val)

constructPutRequests

private List<org.apache.hadoop.hbase.client.Put> constructPutRequests()

validateLoadedData

private void validateLoadedData(org.apache.hadoop.hbase.client.Table table)
                         throws IOException

Throws:

IOException

validateEmpty

private void validateEmpty(Object r1)

validateSizeAndEmpty

private void validateSizeAndEmpty(Object[] results,
 int expectedSize)