Package org.apache.hadoop.hbase.client

Class FromClientSideTest5

java.lang.Object

org.apache.hadoop.hbase.client.FromClientSideTestBase

org.apache.hadoop.hbase.client.FromClientSideTest5

Direct Known Subclasses:

TestFromClientSide5, TestFromClientSide5WithCoprocessor

public class FromClientSideTest5
extends FromClientSideTestBase

Run tests that use the HBase clients; Table. Sets up the HBase mini cluster once at start and runs through all client tests. Each creates a table named for the method and does its stuff against that. Parameterized to run with different registry implementations.

Field Summary

Fields

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

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	FromClientSideTest5(Class<? extends org.apache.hadoop.hbase.client.ConnectionRegistry> registryImpl, int numHedgedReqs)

Method Summary

Modifier and Type	Method	Description
private void	createTableAndValidateTableSchemaModification(org.apache.hadoop.hbase.TableName tableName, boolean modifyTable)	Create table and validate online schema modification
private List<org.apache.hadoop.hbase.client.Result>	doAppend(boolean walUsed)
private List<org.apache.hadoop.hbase.HRegionLocation>	getRegionsInRange(org.apache.hadoop.hbase.TableName tableName, byte[] startKey, byte[] endKey)
private org.apache.hadoop.hbase.client.Result	getReverseScanResult(org.apache.hadoop.hbase.client.Table table, byte[] row)
private void	reverseScanTest(org.apache.hadoop.hbase.client.Table table, org.apache.hadoop.hbase.client.Scan.ReadType readType)
void	testAppend()
void	testAppendWithoutWAL()
void	testBatchAppendWithReturnResultFalse()
void	testCacheOnWriteEvictOnClose()	Tests that cache on write works all the way up from the client-side.
void	testCellSizeLimit()
void	testCellSizeNoLimit()
void	testCellUtilTypeMethods()
void	testCheckAndDelete()
void	testCheckAndDeleteWithCompareOp()
void	testCheckAndMutateWithTimeRange()
void	testCheckAndPut()
void	testCheckAndPutWithCompareOp()
void	testClientPoolRoundRobin()
void	testClientPoolThreadLocal()
void	testCreateTableWithZeroRegionReplicas()
void	testDeleteCFWithMemstoreData()
void	testDeleteLatestVersionOfSpecifiedColumn()
void	testDeleteSpecifiedVersionOfSpecifiedColumn()
void	testDeletesWithReverseScan()
void	testEmptyFilterList()
void	testFilterAllRecords()
void	testFiltersWithReverseScan()
void	testGetClosestRowBefore()
void	testGetRegionsInRange()	Tests getRegionsInRange by creating some regions over which a range of keys spans; then changing the key range.
void	testJira6912()
void	testKeyOnlyFilterWithReverseScan()
void	testModifyTableWithMemstoreData()
void	testModifyTableWithZeroRegionReplicas()
void	testMultiRowMutation()
void	testMultiRowMutationWithFilterConditionWhenConditionMatches()
void	testMultiRowMutationWithFilterConditionWhenConditionNotMatch()
void	testMultiRowMutationWithMultipleConditionsWhenConditionsMatch()
void	testMultiRowMutationWithMultipleConditionsWhenConditionsNotMatch()
void	testMultiRowMutationWithSingleConditionWhenConditionMatches()
void	testMultiRowMutationWithSingleConditionWhenConditionNotMatch()
void	testNonCachedGetRegionLocation()	Tests the non cached version of getRegionLocator by moving a region.
void	testNullWithReverseScan()
void	testRawScanRespectsVersions()
void	testReadWithFilter()	Test for HBASE-17125
void	testReversedScanUnderMultiRegions()	Tests reversed scan under multi regions
void	testRowMutations()
void	testScanMetrics()	Test ScanMetrics
void	testScanNullQualifier()
void	testSimpleMissingWithReverseScan()	Test simple table and non-existent row cases.
void	testSmallReversedScanUnderMultiRegions()	Tests reversed scan under multi regions
void	testSmallScan()
void	testSuperSimpleWithReverseScan()
private void	waitForStoreFileCount(org.apache.hadoop.hbase.regionserver.HStore store, int count, int timeout)

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

Constructor Details

FromClientSideTest5

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

Method Details

testGetClosestRowBefore

@TestTemplate
public void testGetClosestRowBefore()
                             throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getReverseScanResult

private org.apache.hadoop.hbase.client.Result getReverseScanResult(org.apache.hadoop.hbase.client.Table table,
 byte[] row)
                                                            throws IOException

Throws:

IOException

testMultiRowMutation

@TestTemplate
public void testMultiRowMutation()
                          throws Exception

Throws:

Exception

testMultiRowMutationWithSingleConditionWhenConditionMatches

@TestTemplate
public void testMultiRowMutationWithSingleConditionWhenConditionMatches()
                                                                 throws Exception

Throws:

Exception

testMultiRowMutationWithSingleConditionWhenConditionNotMatch

@TestTemplate
public void testMultiRowMutationWithSingleConditionWhenConditionNotMatch()
                                                                  throws Exception

Throws:

Exception

testMultiRowMutationWithMultipleConditionsWhenConditionsMatch

@TestTemplate
public void testMultiRowMutationWithMultipleConditionsWhenConditionsMatch()
                                                                   throws Exception

Throws:

Exception

testMultiRowMutationWithMultipleConditionsWhenConditionsNotMatch

@TestTemplate
public void testMultiRowMutationWithMultipleConditionsWhenConditionsNotMatch()
                                                                      throws Exception

Throws:

Exception

testMultiRowMutationWithFilterConditionWhenConditionMatches

@TestTemplate
public void testMultiRowMutationWithFilterConditionWhenConditionMatches()
                                                                 throws Exception

Throws:

Exception

testMultiRowMutationWithFilterConditionWhenConditionNotMatch

@TestTemplate
public void testMultiRowMutationWithFilterConditionWhenConditionNotMatch()
                                                                  throws Exception

Throws:

Exception

testRowMutations

@TestTemplate
public void testRowMutations()
                      throws Exception

Throws:

Exception

testBatchAppendWithReturnResultFalse

@TestTemplate
public void testBatchAppendWithReturnResultFalse()
                                          throws Exception

Throws:

Exception

testAppend

@TestTemplate
public void testAppend()
                throws Exception

Throws:

Exception

doAppend

private List<org.apache.hadoop.hbase.client.Result> doAppend(boolean walUsed)
                                                      throws IOException

Throws:

IOException

testAppendWithoutWAL

@TestTemplate
public void testAppendWithoutWAL()
                          throws Exception

Throws:

Exception

testClientPoolRoundRobin

@TestTemplate
public void testClientPoolRoundRobin()
                              throws IOException

Throws:

IOException

testClientPoolThreadLocal

@Disabled("Flakey: HBASE-8989")
@TestTemplate
public void testClientPoolThreadLocal()
                               throws IOException

Throws:

IOException

testCheckAndPut

@TestTemplate
public void testCheckAndPut()
                     throws IOException

Throws:

IOException

testCheckAndMutateWithTimeRange

@TestTemplate
public void testCheckAndMutateWithTimeRange()
                                     throws IOException

Throws:

IOException

testCheckAndPutWithCompareOp

@TestTemplate
public void testCheckAndPutWithCompareOp()
                                  throws IOException

Throws:

IOException

testCheckAndDelete

@TestTemplate
public void testCheckAndDelete()
                        throws IOException

Throws:

IOException

testCheckAndDeleteWithCompareOp

@TestTemplate
public void testCheckAndDeleteWithCompareOp()
                                     throws IOException

Throws:

IOException

testScanMetrics

@TestTemplate
public void testScanMetrics()
                     throws Exception

Test ScanMetrics

Throws:

Exception

testCacheOnWriteEvictOnClose

@TestTemplate
public void testCacheOnWriteEvictOnClose()
                                  throws Exception

Tests that cache on write works all the way up from the client-side. Performs inserts, flushes, and compactions, verifying changes in the block cache along the way.

Throws:

Exception

waitForStoreFileCount

private void waitForStoreFileCount(org.apache.hadoop.hbase.regionserver.HStore store,
 int count,
 int timeout)
                            throws InterruptedException

Throws:

InterruptedException

testNonCachedGetRegionLocation

@TestTemplate
public void testNonCachedGetRegionLocation()
                                    throws Exception

Tests the non cached version of getRegionLocator by moving a region.

Throws:

Exception

testGetRegionsInRange

@TestTemplate
public void testGetRegionsInRange()
                           throws Exception

Tests getRegionsInRange by creating some regions over which a range of keys spans; then changing the key range.

Throws:

Exception

getRegionsInRange

private List<org.apache.hadoop.hbase.HRegionLocation> getRegionsInRange(org.apache.hadoop.hbase.TableName tableName,
 byte[] startKey,
 byte[] endKey)
                                                                 throws IOException

Throws:

IOException

testJira6912

@TestTemplate
public void testJira6912()
                  throws Exception

Throws:

Exception

testScanNullQualifier

@TestTemplate
public void testScanNullQualifier()
                           throws IOException

Throws:

IOException

testRawScanRespectsVersions

@TestTemplate
public void testRawScanRespectsVersions()
                                 throws Exception

Throws:

Exception

testEmptyFilterList

@TestTemplate
public void testEmptyFilterList()
                         throws Exception

Throws:

Exception

testSmallScan

@TestTemplate
public void testSmallScan()
                   throws Exception

Throws:

Exception

testSuperSimpleWithReverseScan

@TestTemplate
public void testSuperSimpleWithReverseScan()
                                    throws Exception

Throws:

Exception

testFiltersWithReverseScan

@TestTemplate
public void testFiltersWithReverseScan()
                                throws Exception

Throws:

Exception

testKeyOnlyFilterWithReverseScan

@TestTemplate
public void testKeyOnlyFilterWithReverseScan()
                                      throws Exception

Throws:

Exception

testSimpleMissingWithReverseScan

@TestTemplate
public void testSimpleMissingWithReverseScan()
                                      throws Exception

Test simple table and non-existent row cases.

Throws:

Exception

testNullWithReverseScan

@TestTemplate
public void testNullWithReverseScan()
                             throws Exception

Throws:

Exception

testDeletesWithReverseScan

@TestTemplate
public void testDeletesWithReverseScan()
                                throws Exception

Throws:

Exception

testReversedScanUnderMultiRegions

@TestTemplate
public void testReversedScanUnderMultiRegions()
                                       throws Exception

Tests reversed scan under multi regions

Throws:

Exception

testSmallReversedScanUnderMultiRegions

@TestTemplate
public void testSmallReversedScanUnderMultiRegions()
                                            throws Exception

Tests reversed scan under multi regions

Throws:

Exception

reverseScanTest

private void reverseScanTest(org.apache.hadoop.hbase.client.Table table,
 org.apache.hadoop.hbase.client.Scan.ReadType readType)
                      throws IOException

Throws:

IOException

testFilterAllRecords

@TestTemplate
public void testFilterAllRecords()
                          throws IOException

Throws:

IOException

testCellSizeLimit

@TestTemplate
public void testCellSizeLimit()
                       throws IOException

Throws:

IOException

testCellSizeNoLimit

@TestTemplate
public void testCellSizeNoLimit()
                         throws IOException

Throws:

IOException

testDeleteSpecifiedVersionOfSpecifiedColumn

@TestTemplate
public void testDeleteSpecifiedVersionOfSpecifiedColumn()
                                                 throws Exception

Throws:

Exception

testDeleteLatestVersionOfSpecifiedColumn

@TestTemplate
public void testDeleteLatestVersionOfSpecifiedColumn()
                                              throws Exception

Throws:

Exception

testReadWithFilter

@TestTemplate
public void testReadWithFilter()
                        throws Exception

Test for HBASE-17125

Throws:

Exception

testCellUtilTypeMethods

@TestTemplate
public void testCellUtilTypeMethods()
                             throws IOException

Throws:

IOException

testCreateTableWithZeroRegionReplicas

@TestTemplate
public void testCreateTableWithZeroRegionReplicas()
                                           throws Exception

Throws:

Exception

testModifyTableWithZeroRegionReplicas

@TestTemplate
public void testModifyTableWithZeroRegionReplicas()
                                           throws Exception

Throws:

Exception

testModifyTableWithMemstoreData

@TestTemplate
public void testModifyTableWithMemstoreData()
                                     throws Exception

Throws:

Exception

testDeleteCFWithMemstoreData

@TestTemplate
public void testDeleteCFWithMemstoreData()
                                  throws Exception

Throws:

Exception

createTableAndValidateTableSchemaModification

private void createTableAndValidateTableSchemaModification(org.apache.hadoop.hbase.TableName tableName,
 boolean modifyTable)
                                                    throws Exception

Create table and validate online schema modification

Parameters:

tableName - Table name

modifyTable - Modify table if true otherwise delete column family

Throws:

IOException - in case of failures

Exception