Package org.apache.hadoop.hbase.client

Class FromClientSideTest3

java.lang.Object

org.apache.hadoop.hbase.client.FromClientSideTestBase

org.apache.hadoop.hbase.client.FromClientSideTest3

Direct Known Subclasses:

TestFromClientSide3, TestFromClientSide3WithCoprocessor, TestFromClientSide3WoUnsafe

public class FromClientSideTest3
extends FromClientSideTestBase

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private static int	WAITTABLE_MILLIS

Fields inherited from class org.apache.hadoop.hbase.client.FromClientSideTestBase

FAMILY, INVALID_FAMILY, numHedgedReqs, QUALIFIER, registryImpl, ROW, SLAVES, tableName, TEST_UTIL, VALUE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	FromClientSideTest3(Class<? extends org.apache.hadoop.hbase.client.ConnectionRegistry> registryImpl, int numHedgedReqs)

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)
protected static void	startCluster(Class<?>... cps)
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	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 org.apache.hadoop.hbase.client.FromClientSideTestBase

assertDoubleResult, assertEmptyResult, assertIncrementKey, assertKey, assertNResult, assertNResult, assertNullResult, assertNumKeys, assertRowCount, assertSingleResult, assertSingleResult, assertSingleResult, buildScanner, createScanWithRowFilter, createScanWithRowFilter, deleteColumns, equals, getAllVersionsAndVerify, getClientConf, getConnection, getNumberOfRows, getSingleScanResult, getTestNull, getTestNull, getVerifySingleColumn, getVerifySingleEmpty, getVersionAndVerify, getVersionAndVerifyMissing, getVersionRangeAndVerify, getVersionRangeAndVerifyGreaterThan, initialize, makeN, makeNAscii, makeNBig, makeStamps, parameters, putRows, scanAllVersionsAndVerify, scanTestNull, scanTestNull, scanVerifySingleColumn, scanVerifySingleEmpty, scanVersionAndVerify, scanVersionAndVerifyMissing, scanVersionRangeAndVerify, scanVersionRangeAndVerifyGreaterThan, setUp, singleRowGetTest, singleRowScanTest, splitTable, tearDown, tearDownAfterClass

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

WAITTABLE_MILLIS

private static int WAITTABLE_MILLIS

Constructor Details

FromClientSideTest3

protected FromClientSideTest3(Class<? extends org.apache.hadoop.hbase.client.ConnectionRegistry> registryImpl,
 int numHedgedReqs)

Method Details

startCluster

protected static void startCluster(Class<?>... cps)
                            throws Exception

Throws:

Exception

toList

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

testScanAfterDeletingSpecifiedRow

@TestTemplate
public void testScanAfterDeletingSpecifiedRow()
                                       throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testScanAfterDeletingSpecifiedRowV2

@TestTemplate
public void testScanAfterDeletingSpecifiedRowV2()
                                         throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testPutWithPreBatchMutate

@TestTemplate
public void testPutWithPreBatchMutate()
                               throws Exception

Throws:

Exception

testRowMutationsWithPreBatchMutate

@TestTemplate
public void testRowMutationsWithPreBatchMutate()
                                        throws Exception

Throws:

Exception

testPreBatchMutate

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

Throws:

Exception

testLockLeakWithDelta

@TestTemplate
public void testLockLeakWithDelta()
                           throws Exception,
Throwable

Throws:

Exception

Throwable

testMultiRowMutations

@TestTemplate
public void testMultiRowMutations()
                           throws Exception,
Throwable

Throws:

Exception

Throwable

testMVCCUsingMVCCPreAssign

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

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

@TestTemplate
public void testScanWithBatchSizeReturnIncompleteCells()
                                                throws IOException,
InterruptedException

Throws:

IOException

InterruptedException