Package org.apache.hadoop.hbase.client

Class TestFromClientSide5

java.lang.Object

org.apache.hadoop.hbase.client.FromClientSideBase

org.apache.hadoop.hbase.client.TestFromClientSide5

Direct Known Subclasses:

TestFromClientSideWithCoprocessor5

public class TestFromClientSide5
extends FromClientSideBase

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
static final HBaseClassTestRule	CLASS_RULE
private static final org.slf4j.Logger	LOG
TableNameTestRule	name

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

FAMILY, INVALID_FAMILY, QUALIFIER, ROW, SLAVES, TEST_UTIL, VALUE

Constructor Summary

Constructors

Constructor	Description
TestFromClientSide5()
TestFromClientSide5(Class<? extends org.apache.hadoop.hbase.client.ConnectionRegistry> registry, 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)
static List<Object[]>	parameters()
private void	reverseScanTest(org.apache.hadoop.hbase.client.Table table, boolean small)
static void	tearDownAfterClass()
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	testNegativeTimestamp()
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	testScan_NullQualifier()
void	testScanMetrics()	Test ScanMetrics
void	testScanVariableReuse()	For HBASE-2156
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.FromClientSideBase

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

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

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

name

public TableNameTestRule name

Constructor Details

TestFromClientSide5

TestFromClientSide5()

TestFromClientSide5

public TestFromClientSide5(Class<? extends org.apache.hadoop.hbase.client.ConnectionRegistry> registry,
 int numHedgedReqs)
                    throws Exception

Throws:

Exception

Method Details

parameters

public static List<Object[]> parameters()

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testGetClosestRowBefore

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

testScanVariableReuse

public void testScanVariableReuse()

For HBASE-2156

testMultiRowMutation

public void testMultiRowMutation()
                          throws Exception

Throws:

Exception

testMultiRowMutationWithSingleConditionWhenConditionMatches

public void testMultiRowMutationWithSingleConditionWhenConditionMatches()
                                                                 throws Exception

Throws:

Exception

testMultiRowMutationWithSingleConditionWhenConditionNotMatch

public void testMultiRowMutationWithSingleConditionWhenConditionNotMatch()
                                                                  throws Exception

Throws:

Exception

testMultiRowMutationWithMultipleConditionsWhenConditionsMatch

public void testMultiRowMutationWithMultipleConditionsWhenConditionsMatch()
                                                                   throws Exception

Throws:

Exception

testMultiRowMutationWithMultipleConditionsWhenConditionsNotMatch

public void testMultiRowMutationWithMultipleConditionsWhenConditionsNotMatch()
                                                                      throws Exception

Throws:

Exception

testMultiRowMutationWithFilterConditionWhenConditionMatches

public void testMultiRowMutationWithFilterConditionWhenConditionMatches()
                                                                 throws Exception

Throws:

Exception

testMultiRowMutationWithFilterConditionWhenConditionNotMatch

public void testMultiRowMutationWithFilterConditionWhenConditionNotMatch()
                                                                  throws Exception

Throws:

Exception

testRowMutations

public void testRowMutations()
                      throws Exception

Throws:

Exception

testBatchAppendWithReturnResultFalse

public void testBatchAppendWithReturnResultFalse()
                                          throws Exception

Throws:

Exception

testAppend

public void testAppend()
                throws Exception

Throws:

Exception

doAppend

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

Throws:

IOException

testAppendWithoutWAL

public void testAppendWithoutWAL()
                          throws Exception

Throws:

Exception

testClientPoolRoundRobin

public void testClientPoolRoundRobin()
                              throws IOException

Throws:

IOException

testClientPoolThreadLocal

public void testClientPoolThreadLocal()
                               throws IOException

Throws:

IOException

testCheckAndPut

public void testCheckAndPut()
                     throws IOException

Throws:

IOException

testCheckAndMutateWithTimeRange

public void testCheckAndMutateWithTimeRange()
                                     throws IOException

Throws:

IOException

testCheckAndPutWithCompareOp

public void testCheckAndPutWithCompareOp()
                                  throws IOException

Throws:

IOException

testCheckAndDelete

public void testCheckAndDelete()
                        throws IOException

Throws:

IOException

testCheckAndDeleteWithCompareOp

public void testCheckAndDeleteWithCompareOp()
                                     throws IOException

Throws:

IOException

testScanMetrics

public void testScanMetrics()
                     throws Exception

Test ScanMetrics

Throws:

Exception

testCacheOnWriteEvictOnClose

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

public void testNonCachedGetRegionLocation()
                                    throws Exception

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

Throws:

Exception

testGetRegionsInRange

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

public void testJira6912()
                  throws Exception

Throws:

Exception

testScan_NullQualifier

public void testScan_NullQualifier()
                            throws IOException

Throws:

IOException

testNegativeTimestamp

public void testNegativeTimestamp()
                           throws IOException

Throws:

IOException

testRawScanRespectsVersions

public void testRawScanRespectsVersions()
                                 throws Exception

Throws:

Exception

testEmptyFilterList

public void testEmptyFilterList()
                         throws Exception

Throws:

Exception

testSmallScan

public void testSmallScan()
                   throws Exception

Throws:

Exception

testSuperSimpleWithReverseScan

public void testSuperSimpleWithReverseScan()
                                    throws Exception

Throws:

Exception

testFiltersWithReverseScan

public void testFiltersWithReverseScan()
                                throws Exception

Throws:

Exception

testKeyOnlyFilterWithReverseScan

public void testKeyOnlyFilterWithReverseScan()
                                      throws Exception

Throws:

Exception

testSimpleMissingWithReverseScan

public void testSimpleMissingWithReverseScan()
                                      throws Exception

Test simple table and non-existent row cases.

Throws:

Exception

testNullWithReverseScan

public void testNullWithReverseScan()
                             throws Exception

Throws:

Exception

testDeletesWithReverseScan

public void testDeletesWithReverseScan()
                                throws Exception

Throws:

Exception

testReversedScanUnderMultiRegions

public void testReversedScanUnderMultiRegions()
                                       throws Exception

Tests reversed scan under multi regions

Throws:

Exception

testSmallReversedScanUnderMultiRegions

public void testSmallReversedScanUnderMultiRegions()
                                            throws Exception

Tests reversed scan under multi regions

Throws:

Exception

reverseScanTest

private void reverseScanTest(org.apache.hadoop.hbase.client.Table table,
 boolean small)
                      throws IOException

Throws:

IOException

testFilterAllRecords

public void testFilterAllRecords()
                          throws IOException

Throws:

IOException

testCellSizeLimit

public void testCellSizeLimit()
                       throws IOException

Throws:

IOException

testCellSizeNoLimit

public void testCellSizeNoLimit()
                         throws IOException

Throws:

IOException

testDeleteSpecifiedVersionOfSpecifiedColumn

public void testDeleteSpecifiedVersionOfSpecifiedColumn()
                                                 throws Exception

Throws:

Exception

testDeleteLatestVersionOfSpecifiedColumn

public void testDeleteLatestVersionOfSpecifiedColumn()
                                              throws Exception

Throws:

Exception

testReadWithFilter

public void testReadWithFilter()
                        throws Exception

Test for HBASE-17125

Throws:

Exception

testCellUtilTypeMethods

public void testCellUtilTypeMethods()
                             throws IOException

Throws:

IOException

testCreateTableWithZeroRegionReplicas

public void testCreateTableWithZeroRegionReplicas()
                                           throws Exception

Throws:

Exception

testModifyTableWithZeroRegionReplicas

public void testModifyTableWithZeroRegionReplicas()
                                           throws Exception

Throws:

Exception

testModifyTableWithMemstoreData

public void testModifyTableWithMemstoreData()
                                     throws Exception

Throws:

Exception

testDeleteCFWithMemstoreData

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