org.apache.hadoop.hbase.client

Class TestFromClientSide

java.lang.Object

org.apache.hadoop.hbase.client.TestFromClientSide

Direct Known Subclasses:

TestFromClientSideWithCoprocessor

public class TestFromClientSide
extends Object

Run tests that use the HBase clients; HTable. 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.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestFromClientSide.ExceptionInReseekRegionObserver This is a coprocessor to inject a test failure so that a store scanner.reseek() call will fail with an IOException() on the first call.

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	SLAVES
protected static HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
TestFromClientSide()

Method Summary

Modifier and Type	Method and Description
void	setUp()
static void	setUpBeforeClass()
void	tearDown()
static void	tearDownAfterClass()
void	testAddKeyValue()
void	testAppend()
void	testCacheOnWriteEvictOnClose() Tests that cache on write works all the way up from the client-side.
void	testCheckAndDeleteWithCompareOp()
void	testCheckAndPut()
void	testCheckAndPutWithCompareOp()
void	testClientPoolRoundRobin()
void	testClientPoolThreadLocal()
void	testClientScannerIsResetWhenScanThrowsIOException() Tests the case where a Scan can throw an IOException in the middle of the seek / reseek leaving the server side RegionScanner to be in dirty state.
void	testDeleteFamilyVersion()
void	testDeleteFamilyVersionWithOtherDeletes()
void	testDeletes()
void	testDeletesWithReverseScan()
void	testDuplicateVersions()
void	testFilterAcrossMultipleRegions() Test filters when multiple regions.
void	testFilterAllRecords()
void	testFilters()
void	testFiltersWithReverseScan()
void	testFilterWithLongCompartor()
void	testGet_EmptyTable()
void	testGet_NonExistentRow()
void	testGet_NullQualifier()
void	testGetClosestRowBefore()
void	testGetConfiguration() Verifies that getConfiguration returns the same Configuration object used to create the HTable instance.
void	testGetRegionsInRange()
void	testGetStartEndKeysWithRegionReplicas()
void	testHBase737() test for HBASE-737
void	testIllegalTableDescriptor()
void	testJira6912()
void	testJiraTest1014() HBASE-1014 commit(BatchUpdate) method should return timestamp
void	testJiraTest1182() HBASE-1182 Scan for columns > some timestamp
void	testJiraTest33() HBASE-33 Add a HTable get/obtainScanner method that retrieves all versions of a particular column and row between two timestamps
void	testJiraTest52() HBASE-52 Add a means of scanning over all versions
void	testJiraTest861() HBASE-861 get with timestamp will return a value if there is a version with an earlier timestamp
void	testJiraTest867() HBASE-867 If millions of columns in a column family, hbase scanner won't come up Test will create numRows rows, each with numColsPerRow columns (1 version each), and attempt to scan them all.
void	testKeepDeletedCells() Basic client side validation of HBASE-4536
void	testKeyOnlyFilter()
void	testKeyOnlyFilterWithReverseScan()
void	testListTables()
void	testMajorCompactionBetweenTwoUpdates()
void	testMaxKeyValueSize()
void	testMillions()
void	testMiscHTableStuff()
void	testMultipleRegionsAndBatchPuts()
void	testMultipleRowMultipleFamily()
void	testMultiRowMutation()
void	testNegativeTimestamp()
void	testNonCachedGetRegionLocation()
void	testNull()
void	testNullWithReverseScan()
void	testPurgeFutureDeletes() Basic client side validation of HBASE-10118
void	testPut()
void	testPutNoCF()
void	testRawScanRespectsVersions()
void	testRegionCache()
void	testReversedScanUnderMultiRegions() Tests reversed scan under multi regions
void	testRowMutation()
void	testRowsPut()
void	testRowsPutBufferedManyManyFlushes()
void	testRowsPutBufferedOneFlush()
void	testScan_NullQualifier()
void	testScanMetrics() Test ScanMetrics
void	testScannerFailsAfterRetriesWhenCoprocessorThrowsIOE() Tests the case where a coprocessor throws a regular IOException in the scan.
void	testScannerThrowsExceptionWhenCoprocessorThrowsDNRIOE() Tests the case where a coprocessor throws a DoNotRetryIOException in the scan.
void	testScanVariableReuse() For HBASE-2156
void	testSharedZooKeeper() Deprecated. Tests deprecated functionality. Remove when we are past 1.0.
void	testSimpleMissing() Test simple table and non-existent row cases.
void	testSimpleMissingWithReverseScan() Test simple table and non-existent row cases.
void	testSingleRowMultipleFamily() Test basic puts, gets, scans, and deletes for a single row in a multiple family table.
void	testSmallReversedScanUnderMultiRegions() Tests reversed scan under multi regions
void	testSmallScan()
void	testSuperSimple()
void	testSuperSimpleWithReverseScan()
void	testUnmanagedHConnection() simple test that just executes parts of the client API that accept a pre-created HConnection instance
void	testUnmanagedHConnectionReconnect() test of that unmanaged HConnections are able to reconnect properly (see HBASE-5058)
void	testUpdates()
void	testUpdatesWithMajorCompaction()
void	testVersionLimits()
void	testVersions()
void	testWeirdCacheBehaviour() Test from client side of an involved filter against a multi family that involves deletes.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

TEST_UTIL

protected static final HBaseTestingUtility TEST_UTIL

SLAVES

protected static int SLAVES

Constructor Detail

TestFromClientSide

public TestFromClientSide()

Method Detail

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setUp

public void setUp()
           throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

testKeepDeletedCells

public void testKeepDeletedCells()
                          throws Exception

Basic client side validation of HBASE-4536

Throws:

Exception

testPurgeFutureDeletes

public void testPurgeFutureDeletes()
                            throws Exception

Basic client side validation of HBASE-10118

Throws:

Exception

testSharedZooKeeper

@Deprecated
public void testSharedZooKeeper()
                                     throws Exception

Deprecated. Tests deprecated functionality. Remove when we are past 1.0.

Throws:

Exception

testGetConfiguration

public void testGetConfiguration()
                          throws Exception

Verifies that getConfiguration returns the same Configuration object used to create the HTable instance.

Throws:

Exception

testWeirdCacheBehaviour

public void testWeirdCacheBehaviour()
                             throws Exception

Test from client side of an involved filter against a multi family that involves deletes.

Throws:

Exception

testFilterAcrossMultipleRegions

public void testFilterAcrossMultipleRegions()
                                     throws IOException,
                                            InterruptedException

Test filters when multiple regions. It does counts. Needs eye-balling of logs to ensure that we're not scanning more regions that we're supposed to. Related to the TestFilterAcrossRegions over in the o.a.h.h.filter package.

Throws:

IOException

InterruptedException

testClientScannerIsResetWhenScanThrowsIOException

public void testClientScannerIsResetWhenScanThrowsIOException()
                                                       throws IOException,
                                                              InterruptedException

Tests the case where a Scan can throw an IOException in the middle of the seek / reseek leaving the server side RegionScanner to be in dirty state. The client has to ensure that the ClientScanner does not get an exception and also sees all the data.

Throws:

IOException

InterruptedException

testScannerThrowsExceptionWhenCoprocessorThrowsDNRIOE

public void testScannerThrowsExceptionWhenCoprocessorThrowsDNRIOE()
                                                           throws IOException,
                                                                  InterruptedException

Tests the case where a coprocessor throws a DoNotRetryIOException in the scan. The expectation is that the exception will bubble up to the client scanner instead of being retried.

Throws:

IOException

InterruptedException

testScannerFailsAfterRetriesWhenCoprocessorThrowsIOE

public void testScannerFailsAfterRetriesWhenCoprocessorThrowsIOE()
                                                          throws IOException,
                                                                 InterruptedException

Tests the case where a coprocessor throws a regular IOException in the scan. The expectation is that the we will keep on retrying, but fail after the retries are exhausted instead of retrying indefinitely.

Throws:

IOException

InterruptedException

testSuperSimple

public void testSuperSimple()
                     throws Exception

Throws:

Exception

testMaxKeyValueSize

public void testMaxKeyValueSize()
                         throws Exception

Throws:

Exception

testFilters

public void testFilters()
                 throws Exception

Throws:

Exception

testFilterWithLongCompartor

public void testFilterWithLongCompartor()
                                 throws Exception

Throws:

Exception

testKeyOnlyFilter

public void testKeyOnlyFilter()
                       throws Exception

Throws:

Exception

testSimpleMissing

public void testSimpleMissing()
                       throws Exception

Test simple table and non-existent row cases.

Throws:

Exception

testSingleRowMultipleFamily

public void testSingleRowMultipleFamily()
                                 throws Exception

Test basic puts, gets, scans, and deletes for a single row in a multiple family table.

Throws:

Exception

testNull

public void testNull()
              throws Exception

Throws:

Exception

testVersions

public void testVersions()
                  throws Exception

Throws:

Exception

testVersionLimits

public void testVersionLimits()
                       throws Exception

Throws:

Exception

testDeleteFamilyVersion

public void testDeleteFamilyVersion()
                             throws Exception

Throws:

Exception

testDeleteFamilyVersionWithOtherDeletes

public void testDeleteFamilyVersionWithOtherDeletes()
                                             throws Exception

Throws:

Exception

testDeletes

public void testDeletes()
                 throws Exception

Throws:

Exception

testMillions

public void testMillions()
                  throws Exception

Throws:

Exception

testMultipleRegionsAndBatchPuts

public void testMultipleRegionsAndBatchPuts()
                                     throws Exception

Throws:

Exception

testMultipleRowMultipleFamily

public void testMultipleRowMultipleFamily()
                                   throws Exception

Throws:

Exception

testJiraTest867

public void testJiraTest867()
                     throws Exception

HBASE-867 If millions of columns in a column family, hbase scanner won't come up Test will create numRows rows, each with numColsPerRow columns (1 version each), and attempt to scan them all. To test at scale, up numColsPerRow to the millions (have not gotten that to work running as junit though)

Throws:

Exception

testJiraTest861

public void testJiraTest861()
                     throws Exception

HBASE-861 get with timestamp will return a value if there is a version with an earlier timestamp

Throws:

Exception

testJiraTest33

public void testJiraTest33()
                    throws Exception

HBASE-33 Add a HTable get/obtainScanner method that retrieves all versions of a particular column and row between two timestamps

Throws:

Exception

testJiraTest1014

public void testJiraTest1014()
                      throws Exception

HBASE-1014 commit(BatchUpdate) method should return timestamp

Throws:

Exception

testJiraTest1182

public void testJiraTest1182()
                      throws Exception

HBASE-1182 Scan for columns > some timestamp

Throws:

Exception

testJiraTest52

public void testJiraTest52()
                    throws Exception

HBASE-52 Add a means of scanning over all versions

Throws:

Exception

testDuplicateVersions

public void testDuplicateVersions()
                           throws Exception

Throws:

Exception

testUpdates

public void testUpdates()
                 throws Exception

Throws:

Exception

testUpdatesWithMajorCompaction

public void testUpdatesWithMajorCompaction()
                                    throws Exception

Throws:

Exception

testMajorCompactionBetweenTwoUpdates

public void testMajorCompactionBetweenTwoUpdates()
                                          throws Exception

Throws:

Exception

testGet_EmptyTable

public void testGet_EmptyTable()
                        throws IOException

Throws:

IOException

testGet_NullQualifier

public void testGet_NullQualifier()
                           throws IOException

Throws:

IOException

testGet_NonExistentRow

public void testGet_NonExistentRow()
                            throws IOException

Throws:

IOException

testPut

public void testPut()
             throws IOException

Throws:

IOException

testPutNoCF

public void testPutNoCF()
                 throws IOException

Throws:

IOException

testRowsPut

public void testRowsPut()
                 throws IOException

Throws:

IOException

testRowsPutBufferedOneFlush

public void testRowsPutBufferedOneFlush()
                                 throws IOException

Throws:

IOException

testRowsPutBufferedManyManyFlushes

public void testRowsPutBufferedManyManyFlushes()
                                        throws IOException

Throws:

IOException

testAddKeyValue

public void testAddKeyValue()
                     throws IOException

Throws:

IOException

testHBase737

public void testHBase737()
                  throws IOException

test for HBASE-737

Throws:

IOException

testListTables

public void testListTables()
                    throws IOException,
                           InterruptedException

Throws:

IOException

InterruptedException

testUnmanagedHConnection

public void testUnmanagedHConnection()
                              throws IOException

simple test that just executes parts of the client API that accept a pre-created HConnection instance

Throws:

IOException

testUnmanagedHConnectionReconnect

public void testUnmanagedHConnectionReconnect()
                                       throws Exception

test of that unmanaged HConnections are able to reconnect properly (see HBASE-5058)

Throws:

Exception

testMiscHTableStuff

public void testMiscHTableStuff()
                         throws IOException

Throws:

IOException

testGetClosestRowBefore

public void testGetClosestRowBefore()
                             throws IOException,
                                    InterruptedException

Throws:

IOException

InterruptedException

testScanVariableReuse

public void testScanVariableReuse()
                           throws Exception

For HBASE-2156

Throws:

Exception

testMultiRowMutation

public void testMultiRowMutation()
                          throws Exception

Throws:

Exception

testRowMutation

public void testRowMutation()
                     throws Exception

Throws:

Exception

testAppend

public void testAppend()
                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

testCheckAndPutWithCompareOp

public void testCheckAndPutWithCompareOp()
                                  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

testNonCachedGetRegionLocation

public void testNonCachedGetRegionLocation()
                                    throws Exception

Throws:

Exception

testGetRegionsInRange

public void testGetRegionsInRange()
                           throws Exception

Throws:

Exception

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

testIllegalTableDescriptor

public void testIllegalTableDescriptor()
                                throws Exception

Throws:

Exception

testRawScanRespectsVersions

public void testRawScanRespectsVersions()
                                 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

testGetStartEndKeysWithRegionReplicas

public void testGetStartEndKeysWithRegionReplicas()
                                           throws IOException

Throws:

IOException

testFilterAllRecords

public void testFilterAllRecords()
                          throws IOException

Throws:

IOException

testRegionCache

public void testRegionCache()
                     throws IOException

Throws:

IOException