Package org.apache.hadoop.hbase.client

Class FromClientSide3TestBase

java.lang.Object

org.apache.hadoop.hbase.client.FromClientSide3TestBase

Direct Known Subclasses:

TestFromClientSide3, TestFromClientSide3WoUnsafe

public class FromClientSide3TestBase
extends Object

Nested Class Summary

Nested Classes

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

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
FromClientSide3TestBase()

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(org.junit.jupiter.api.TestInfo testInfo)
static void	shutdownCluster()
protected static void	startCluster()
void	tearDown()
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

LOG

private static final org.slf4j.Logger LOG

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

WAITTABLE_MILLIS

private static int WAITTABLE_MILLIS

FAMILY

private static byte[] FAMILY

SLAVES

private static int SLAVES

ROW

private static byte[] ROW

ANOTHERROW

private static byte[] ANOTHERROW

QUALIFIER

private static byte[] QUALIFIER

VALUE

private static byte[] VALUE

COL_QUAL

private static byte[] COL_QUAL

VAL_BYTES

private static byte[] VAL_BYTES

ROW_BYTES

private static byte[] ROW_BYTES

tableName

private org.apache.hadoop.hbase.TableName tableName

Constructor Details

FromClientSide3TestBase

public FromClientSide3TestBase()

Method Details

startCluster

protected static void startCluster()
                            throws Exception

Throws:

Exception

shutdownCluster

@AfterAll
public static void shutdownCluster()
                            throws Exception

Throws:

Exception

setUp

@BeforeEach
public void setUp(org.junit.jupiter.api.TestInfo testInfo)
           throws Exception

Throws:

Exception

tearDown

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

@Test
public void testScanAfterDeletingSpecifiedRow()
                                       throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testScanAfterDeletingSpecifiedRowV2

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

@Test
public void testAdvancedConfigOverride()
                                throws Exception

Throws:

Exception

testHTableBatchWithEmptyPut

@Test
public void testHTableBatchWithEmptyPut()
                                 throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testHTableWithLargeBatch

@Test
public void testHTableWithLargeBatch()
                              throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testBatchWithRowMutation

@Test
public void testBatchWithRowMutation()
                              throws Exception

Throws:

Exception

testBatchWithCheckAndMutate

@Test
public void testBatchWithCheckAndMutate()
                                 throws Exception

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

@Test
public void testHTableExistsBeforeGet()
                               throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testHTableExistsAllBeforeGet

@Test
public void testHTableExistsAllBeforeGet()
                                  throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testHTableExistsMethodMultipleRegionsSingleGet

@Test
public void testHTableExistsMethodMultipleRegionsSingleGet()
                                                    throws Exception

Throws:

Exception

testHTableExistsMethodMultipleRegionsMultipleGets

@Test
public void testHTableExistsMethodMultipleRegionsMultipleGets()
                                                       throws Exception

Throws:

Exception

testGetEmptyRow

@Test
public void testGetEmptyRow()
                     throws Exception

Throws:

Exception

testConnectionDefaultUsesCodec

@Test
public void testConnectionDefaultUsesCodec()
                                    throws Exception

Throws:

Exception

testPutWithPreBatchMutate

@Test
public void testPutWithPreBatchMutate()
                               throws Exception

Throws:

Exception

testRowMutationsWithPreBatchMutate

@Test
public void testRowMutationsWithPreBatchMutate()
                                        throws Exception

Throws:

Exception

testPreBatchMutate

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

Throws:

Exception

testLockLeakWithDelta

@Test
public void testLockLeakWithDelta()
                           throws Exception,
Throwable

Throws:

Exception

Throwable

testMultiRowMutations

@Test
public void testMultiRowMutations()
                           throws Exception,
Throwable

Throws:

Exception

Throwable

testMVCCUsingMVCCPreAssign

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

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

@Test
public void testScanWithBatchSizeReturnIncompleteCells()
                                                throws IOException,
InterruptedException

Throws:

IOException

InterruptedException