org.apache.hadoop.hbase.client

Class TestMultiParallel

java.lang.Object

org.apache.hadoop.hbase.client.TestMultiParallel

public class TestMultiParallel
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestMultiParallel.MyMasterObserver

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
TestMultiParallel()

Method Summary

Modifier and Type	Method and 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	testActiveThreadsCount() This is for testing the active number of threads that were used while doing a batch operation.
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()
void	testNonceCollision()
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 Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

UTIL

private static final HBaseTestingUtility 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 Detail

TestMultiParallel

public TestMultiParallel()

Method Detail

beforeClass

public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

public static void afterClass()
                       throws Exception

Throws:

Exception

before

public void before()
            throws Exception

Throws:

Exception

makeKeys

private static byte[][] makeKeys()

testActiveThreadsCount

public void testActiveThreadsCount()
                            throws Exception

This is for testing the active number of threads that were used while doing a batch operation. It inserts one row per region via the batch operation, and then checks the number of active threads.

For HBASE-3553

Throws:

Exception

testBatchWithGet

public void testBatchWithGet()
                      throws Exception

Throws:

Exception

testBadFam

public void testBadFam()
                throws Exception

Throws:

Exception

testFlushCommitsNoAbort

public void testFlushCommitsNoAbort()
                             throws Exception

Throws:

Exception

testFlushCommitsWithAbort

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

public void testBatchWithPut()
                      throws Exception

Throws:

Exception

testBatchWithDelete

public void testBatchWithDelete()
                         throws Exception

Throws:

Exception

testHTableDeleteWithList

public void testHTableDeleteWithList()
                              throws Exception

Throws:

Exception

testBatchWithManyColsInOneRowGetAndPut

public void testBatchWithManyColsInOneRowGetAndPut()
                                            throws Exception

Throws:

Exception

testBatchWithIncrementAndAppend

public void testBatchWithIncrementAndAppend()
                                     throws Exception

Throws:

Exception

testNonceCollision

public void testNonceCollision()
                        throws Exception

Throws:

Exception

testBatchWithMixedActions

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)