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
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classstatic class -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final org.slf4j.Loggerprivate static intFields inherited from class org.apache.hadoop.hbase.client.FromClientSideTestBase
FAMILY, INVALID_FAMILY, numHedgedReqs, QUALIFIER, registryImpl, ROW, SLAVES, tableName, TEST_UTIL, VALUE -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedFromClientSideTest3(Class<? extends org.apache.hadoop.hbase.client.ConnectionRegistry> registryImpl, int numHedgedReqs) -
Method Summary
Modifier and TypeMethodDescriptionprivate static voidassertNoLocks(org.apache.hadoop.hbase.TableName tableName) private static org.apache.hadoop.hbase.regionserver.HRegionfind(org.apache.hadoop.hbase.TableName tableName) private static <T extends org.apache.hadoop.hbase.coprocessor.RegionObserver>
T(package private) static byte[]generateHugeValue(int size) protected static voidstartCluster(Class<?>... cps) voidvoidvoidA 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 voidtestPreBatchMutate(org.apache.hadoop.hbase.TableName tableName, Runnable rn) voidvoidvoidvoidvoidprivate 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
-
Field Details
-
LOG
-
WAITTABLE_MILLIS
-
-
Constructor Details
-
FromClientSideTest3
protected FromClientSideTest3(Class<? extends org.apache.hadoop.hbase.client.ConnectionRegistry> registryImpl, int numHedgedReqs)
-
-
Method Details
-
startCluster
- Throws:
Exception
-
toList
-
testScanAfterDeletingSpecifiedRow
@TestTemplate public void testScanAfterDeletingSpecifiedRow() throws IOException, InterruptedException- Throws:
IOExceptionInterruptedException
-
testScanAfterDeletingSpecifiedRowV2
@TestTemplate public void testScanAfterDeletingSpecifiedRowV2() throws IOException, InterruptedException- Throws:
IOExceptionInterruptedException
-
testPutWithPreBatchMutate
- Throws:
Exception
-
testRowMutationsWithPreBatchMutate
- Throws:
Exception
-
testPreBatchMutate
private void testPreBatchMutate(org.apache.hadoop.hbase.TableName tableName, Runnable rn) throws Exception - Throws:
Exception
-
testLockLeakWithDelta
-
testMultiRowMutations
-
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. 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:
IOExceptionInterruptedException
-
assertNoLocks
private static void assertNoLocks(org.apache.hadoop.hbase.TableName tableName) throws IOException, InterruptedException - Throws:
IOExceptionInterruptedException
-
find
private static org.apache.hadoop.hbase.regionserver.HRegion find(org.apache.hadoop.hbase.TableName tableName) throws IOException, InterruptedException - Throws:
IOExceptionInterruptedException
-
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:
IOExceptionInterruptedException
-
generateHugeValue
-
testScanWithBatchSizeReturnIncompleteCells
@TestTemplate public void testScanWithBatchSizeReturnIncompleteCells() throws IOException, InterruptedException- Throws:
IOExceptionInterruptedException
-