Package org.apache.hadoop.hbase.client

Class TestFromClientSide3

java.lang.Object

org.apache.hadoop.hbase.client.TestFromClientSide3

Direct Known Subclasses:

TestFromClientSide3WoUnsafe

public class TestFromClientSide3
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestFromClientSide3.WaitingForMultiMutationsObserver
static class	TestFromClientSide3.WaitingForScanObserver

Field Summary

Fields

Modifier and Type	Field	Description
private static final byte[]	ANOTHERROW
static final HBaseClassTestRule	CLASS_RULE
private static final byte[]	COL_QUAL
private static byte[]	FAMILY
private static final org.slf4j.Logger	LOG
org.junit.rules.TestName	name
private static final byte[]	QUALIFIER
private static final byte[]	ROW
private static final byte[]	ROW_BYTES
private static int	SLAVES
private org.apache.hadoop.hbase.TableName	tableName
private static final HBaseTestingUtil	TEST_UTIL
private static final byte[]	VAL_BYTES
private static final byte[]	VALUE
private static final int	WAITTABLE_MILLIS

Constructor Summary

Constructors

Constructor	Description
TestFromClientSide3()

Method Summary

Modifier and Type	Method	Description
private static void	assertNoLocks(org.apache.hadoop.hbase.TableName tableName)
private static org.apache.hadoop.hbase.regionserver.HRegion	find(org.apache.hadoop.hbase.TableName tableName)
private static <T extends org.apache.hadoop.hbase.coprocessor.RegionObserver> T	find(org.apache.hadoop.hbase.TableName tableName, Class<T> clz)
(package private) static byte[]	generateHugeValue(int size)
private int	getStoreFileCount(org.apache.hadoop.hbase.client.Admin admin, org.apache.hadoop.hbase.ServerName serverName, org.apache.hadoop.hbase.client.RegionInfo region)
private void	performMultiplePutAndFlush(org.apache.hadoop.hbase.client.Admin admin, org.apache.hadoop.hbase.client.Table table, byte[] row, byte[] family, int nFlushes, int nPuts)
private void	randomCFPuts(org.apache.hadoop.hbase.client.Table table, byte[] row, byte[] family, int nPuts)
void	setUp()
static void	setUpBeforeClass()
void	tearDown()
static void	tearDownAfterClass()
void	testAdvancedConfigOverride()
void	testBatchWithCheckAndMutate()
void	testBatchWithRowMutation()
void	testConnectionDefaultUsesCodec()
void	testGetEmptyRow()
void	testHTableBatchWithEmptyPut()
void	testHTableExistsAllBeforeGet()
void	testHTableExistsBeforeGet()
void	testHTableExistsMethodMultipleRegionsMultipleGets()
void	testHTableExistsMethodMultipleRegionsSingleGet()
void	testHTableExistsMethodSingleRegionMultipleGets()
void	testHTableExistsMethodSingleRegionSingleGet()
void	testHTableWithLargeBatch()
void	testLockLeakWithDelta()
void	testMultiRowMutations()
void	testMVCCUsingMVCCPreAssign()	A test case for issue HBASE-17482 After combile seqid with mvcc readpoint, seqid/mvcc is acquired and stamped onto cells in the append thread, a countdown latch is used to ensure that happened before cells can be put into memstore.
private void	testPreBatchMutate(org.apache.hadoop.hbase.TableName tableName, Runnable rn)
void	testPutThenGetWithMultipleThreads()
void	testPutWithPreBatchMutate()
void	testRowMutationsWithPreBatchMutate()
void	testScanAfterDeletingSpecifiedRow()
void	testScanAfterDeletingSpecifiedRowV2()
void	testScanWithBatchSizeReturnIncompleteCells()
private static List<org.apache.hadoop.hbase.Cell>	toList(org.apache.hadoop.hbase.client.ResultScanner scanner)

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

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

WAITTABLE_MILLIS

private static final int WAITTABLE_MILLIS

See Also:

• Constant Field Values

FAMILY

private static byte[] FAMILY

SLAVES

private static int SLAVES

ROW

private static final byte[] ROW

ANOTHERROW

private static final byte[] ANOTHERROW

QUALIFIER

private static final byte[] QUALIFIER

VALUE

private static final byte[] VALUE

COL_QUAL

private static final byte[] COL_QUAL

VAL_BYTES

private static final byte[] VAL_BYTES

ROW_BYTES

private static final byte[] ROW_BYTES

name

public org.junit.rules.TestName name

tableName

private org.apache.hadoop.hbase.TableName tableName

Constructor Details

TestFromClientSide3

public TestFromClientSide3()

Method Details

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setUp

public void setUp()
           throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

randomCFPuts

private void randomCFPuts(org.apache.hadoop.hbase.client.Table table,
 byte[] row,
 byte[] family,
 int nPuts)
                   throws Exception

Throws:

Exception

performMultiplePutAndFlush

private void performMultiplePutAndFlush(org.apache.hadoop.hbase.client.Admin admin,
 org.apache.hadoop.hbase.client.Table table,
 byte[] row,
 byte[] family,
 int nFlushes,
 int nPuts)
                                 throws Exception

Throws:

Exception

toList

private static List<org.apache.hadoop.hbase.Cell> toList(org.apache.hadoop.hbase.client.ResultScanner scanner)

testScanAfterDeletingSpecifiedRow

public void testScanAfterDeletingSpecifiedRow()
                                       throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testScanAfterDeletingSpecifiedRowV2

public void testScanAfterDeletingSpecifiedRowV2()
                                         throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getStoreFileCount

private int getStoreFileCount(org.apache.hadoop.hbase.client.Admin admin,
 org.apache.hadoop.hbase.ServerName serverName,
 org.apache.hadoop.hbase.client.RegionInfo region)
                       throws IOException

Throws:

IOException

testAdvancedConfigOverride

public void testAdvancedConfigOverride()
                                throws Exception

Throws:

Exception

testHTableBatchWithEmptyPut

public void testHTableBatchWithEmptyPut()
                                 throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testHTableWithLargeBatch

public void testHTableWithLargeBatch()
                              throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testBatchWithRowMutation

public void testBatchWithRowMutation()
                              throws Exception

Throws:

Exception

testBatchWithCheckAndMutate

public void testBatchWithCheckAndMutate()
                                 throws Exception

Throws:

Exception

testHTableExistsMethodSingleRegionSingleGet

public void testHTableExistsMethodSingleRegionSingleGet()
                                                 throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testHTableExistsMethodSingleRegionMultipleGets

public void testHTableExistsMethodSingleRegionMultipleGets()
                                                    throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testHTableExistsBeforeGet

public void testHTableExistsBeforeGet()
                               throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testHTableExistsAllBeforeGet

public void testHTableExistsAllBeforeGet()
                                  throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testHTableExistsMethodMultipleRegionsSingleGet

public void testHTableExistsMethodMultipleRegionsSingleGet()
                                                    throws Exception

Throws:

Exception

testHTableExistsMethodMultipleRegionsMultipleGets

public void testHTableExistsMethodMultipleRegionsMultipleGets()
                                                       throws Exception

Throws:

Exception

testGetEmptyRow

public void testGetEmptyRow()
                     throws Exception

Throws:

Exception

testConnectionDefaultUsesCodec

public void testConnectionDefaultUsesCodec()
                                    throws Exception

Throws:

Exception

testPutWithPreBatchMutate

public void testPutWithPreBatchMutate()
                               throws Exception

Throws:

Exception

testRowMutationsWithPreBatchMutate

public void testRowMutationsWithPreBatchMutate()
                                        throws Exception

Throws:

Exception

testPreBatchMutate

private void testPreBatchMutate(org.apache.hadoop.hbase.TableName tableName,
 Runnable rn)
                         throws Exception

Throws:

Exception

testLockLeakWithDelta

public void testLockLeakWithDelta()
                           throws Exception,
Throwable

Throws:

Exception

Throwable

testMultiRowMutations

public void testMultiRowMutations()
                           throws Exception,
Throwable

Throws:

Exception

Throwable

testMVCCUsingMVCCPreAssign

public void testMVCCUsingMVCCPreAssign()
                                throws IOException,
InterruptedException

A test case for issue HBASE-17482 After combile seqid with mvcc readpoint, seqid/mvcc is acquired and stamped onto cells in the append thread, a countdown latch is used to ensure that happened before cells can be put into memstore. But the MVCCPreAssign patch(HBASE-16698) make the seqid/mvcc acquirement in handler thread and stamping in append thread No countdown latch to assure cells in memstore are stamped with seqid/mvcc. If cells without mvcc(A.K.A mvcc=0) are put into memstore, then a scanner with a smaller readpoint can see these data, which disobey the multi version concurrency control rules. This test case is to reproduce this scenario.

Throws:

IOException

InterruptedException

testPutThenGetWithMultipleThreads

public void testPutThenGetWithMultipleThreads()
                                       throws Exception

Throws:

Exception

assertNoLocks

private static void assertNoLocks(org.apache.hadoop.hbase.TableName tableName)
                           throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

find

private static org.apache.hadoop.hbase.regionserver.HRegion find(org.apache.hadoop.hbase.TableName tableName)
                                                          throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

find

private static <T extends org.apache.hadoop.hbase.coprocessor.RegionObserver>
T find(org.apache.hadoop.hbase.TableName tableName,
 Class<T> clz)
throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

generateHugeValue

static byte[] generateHugeValue(int size)

testScanWithBatchSizeReturnIncompleteCells

public void testScanWithBatchSizeReturnIncompleteCells()
                                                throws IOException,
InterruptedException

Throws:

IOException

InterruptedException