Package org.apache.hadoop.hbase.client
Class FromClientSide3TestBase
java.lang.Object
org.apache.hadoop.hbase.client.FromClientSide3TestBase
- Direct Known Subclasses:
- TestFromClientSide3,- TestFromClientSide3WoUnsafe
- 
Nested Class SummaryNested ClassesModifier and TypeClassDescriptionstatic classstatic class
- 
Field SummaryFieldsModifier and TypeFieldDescriptionprivate static byte[]private static byte[]private static byte[]private static final org.slf4j.Loggerprivate static byte[]private static byte[]private static byte[]private static intprivate org.apache.hadoop.hbase.TableNameprivate static final HBaseTestingUtilprivate static byte[]private static byte[]private static int
- 
Constructor SummaryConstructors
- 
Method SummaryModifier 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) private intgetStoreFileCount(org.apache.hadoop.hbase.client.Admin admin, org.apache.hadoop.hbase.ServerName serverName, org.apache.hadoop.hbase.client.RegionInfo region) private voidperformMultiplePutAndFlush(org.apache.hadoop.hbase.client.Admin admin, org.apache.hadoop.hbase.client.Table table, byte[] row, byte[] family, int nFlushes, int nPuts) private voidrandomCFPuts(org.apache.hadoop.hbase.client.Table table, byte[] row, byte[] family, int nPuts) voidsetUp(org.junit.jupiter.api.TestInfo testInfo) static voidprotected static voidvoidtearDown()voidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidA 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) voidvoidvoidvoidvoidvoidprivate static List<org.apache.hadoop.hbase.Cell>toList(org.apache.hadoop.hbase.client.ResultScanner scanner) 
- 
Field Details- 
LOG
- 
TEST_UTIL
- 
WAITTABLE_MILLIS
- 
FAMILY
- 
SLAVES
- 
ROW
- 
ANOTHERROW
- 
QUALIFIER
- 
VALUE
- 
COL_QUAL
- 
VAL_BYTES
- 
ROW_BYTES
- 
tableName
 
- 
- 
Constructor Details- 
FromClientSide3TestBasepublic FromClientSide3TestBase()
 
- 
- 
Method Details- 
startCluster- Throws:
- Exception
 
- 
shutdownCluster- Throws:
- Exception
 
- 
setUp- Throws:
- Exception
 
- 
tearDown- Throws:
- Exception
 
- 
randomCFPutsprivate void randomCFPuts(org.apache.hadoop.hbase.client.Table table, byte[] row, byte[] family, int nPuts) throws Exception - Throws:
- Exception
 
- 
performMultiplePutAndFlushprivate 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
- 
testScanAfterDeletingSpecifiedRow- Throws:
- IOException
- InterruptedException
 
- 
testScanAfterDeletingSpecifiedRowV2- Throws:
- IOException
- InterruptedException
 
- 
getStoreFileCountprivate 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- Throws:
- Exception
 
- 
testHTableBatchWithEmptyPut- Throws:
- IOException
- InterruptedException
 
- 
testHTableWithLargeBatch- Throws:
- IOException
- InterruptedException
 
- 
testBatchWithRowMutation- Throws:
- Exception
 
- 
testBatchWithCheckAndMutate- Throws:
- Exception
 
- 
testHTableExistsMethodSingleRegionSingleGet@Test public void testHTableExistsMethodSingleRegionSingleGet() throws IOException, InterruptedException- Throws:
- IOException
- InterruptedException
 
- 
testHTableExistsMethodSingleRegionMultipleGets@Test public void testHTableExistsMethodSingleRegionMultipleGets() throws IOException, InterruptedException- Throws:
- IOException
- InterruptedException
 
- 
testHTableExistsBeforeGet- Throws:
- IOException
- InterruptedException
 
- 
testHTableExistsAllBeforeGet- Throws:
- IOException
- InterruptedException
 
- 
testHTableExistsMethodMultipleRegionsSingleGet- Throws:
- Exception
 
- 
testHTableExistsMethodMultipleRegionsMultipleGets- Throws:
- Exception
 
- 
testGetEmptyRow- Throws:
- Exception
 
- 
testConnectionDefaultUsesCodec- Throws:
- Exception
 
- 
testPutWithPreBatchMutate- Throws:
- Exception
 
- 
testRowMutationsWithPreBatchMutate- Throws:
- Exception
 
- 
testPreBatchMutateprivate void testPreBatchMutate(org.apache.hadoop.hbase.TableName tableName, Runnable rn) throws Exception - Throws:
- Exception
 
- 
testLockLeakWithDelta
- 
testMultiRowMutations
- 
testMVCCUsingMVCCPreAssignA 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- Throws:
- Exception
 
- 
assertNoLocksprivate static void assertNoLocks(org.apache.hadoop.hbase.TableName tableName) throws IOException, InterruptedException - Throws:
- IOException
- InterruptedException
 
- 
findprivate static org.apache.hadoop.hbase.regionserver.HRegion find(org.apache.hadoop.hbase.TableName tableName) throws IOException, InterruptedException - Throws:
- IOException
- InterruptedException
 
- 
findprivate 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
- 
testScanWithBatchSizeReturnIncompleteCells@Test public void testScanWithBatchSizeReturnIncompleteCells() throws IOException, InterruptedException- Throws:
- IOException
- InterruptedException
 
 
-