public class TestFromClientSide
extends java.lang.Object
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.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.
|
Modifier and Type | Field and Description |
---|---|
protected static int |
SLAVES |
protected static HBaseTestingUtility |
TEST_UTIL |
Constructor and Description |
---|
TestFromClientSide() |
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.
|
protected static final HBaseTestingUtility TEST_UTIL
protected static int SLAVES
public static void setUpBeforeClass() throws java.lang.Exception
java.lang.Exception
public static void tearDownAfterClass() throws java.lang.Exception
java.lang.Exception
public void setUp() throws java.lang.Exception
java.lang.Exception
public void tearDown() throws java.lang.Exception
java.lang.Exception
public void testKeepDeletedCells() throws java.lang.Exception
java.lang.Exception
public void testPurgeFutureDeletes() throws java.lang.Exception
java.lang.Exception
@Deprecated public void testSharedZooKeeper() throws java.lang.Exception
java.lang.Exception
public void testGetConfiguration() throws java.lang.Exception
java.lang.Exception
public void testWeirdCacheBehaviour() throws java.lang.Exception
java.lang.Exception
public void testFilterAcrossMultipleRegions() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public void testClientScannerIsResetWhenScanThrowsIOException() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public void testScannerThrowsExceptionWhenCoprocessorThrowsDNRIOE() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public void testScannerFailsAfterRetriesWhenCoprocessorThrowsIOE() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public void testSuperSimple() throws java.lang.Exception
java.lang.Exception
public void testMaxKeyValueSize() throws java.lang.Exception
java.lang.Exception
public void testFilters() throws java.lang.Exception
java.lang.Exception
public void testFilterWithLongCompartor() throws java.lang.Exception
java.lang.Exception
public void testKeyOnlyFilter() throws java.lang.Exception
java.lang.Exception
public void testSimpleMissing() throws java.lang.Exception
java.lang.Exception
public void testSingleRowMultipleFamily() throws java.lang.Exception
java.lang.Exception
public void testNull() throws java.lang.Exception
java.lang.Exception
public void testVersions() throws java.lang.Exception
java.lang.Exception
public void testVersionLimits() throws java.lang.Exception
java.lang.Exception
public void testDeleteFamilyVersion() throws java.lang.Exception
java.lang.Exception
public void testDeleteFamilyVersionWithOtherDeletes() throws java.lang.Exception
java.lang.Exception
public void testDeletes() throws java.lang.Exception
java.lang.Exception
public void testMillions() throws java.lang.Exception
java.lang.Exception
public void testMultipleRegionsAndBatchPuts() throws java.lang.Exception
java.lang.Exception
public void testMultipleRowMultipleFamily() throws java.lang.Exception
java.lang.Exception
public void testJiraTest867() throws java.lang.Exception
java.lang.Exception
public void testJiraTest861() throws java.lang.Exception
java.lang.Exception
public void testJiraTest33() throws java.lang.Exception
java.lang.Exception
public void testJiraTest1014() throws java.lang.Exception
java.lang.Exception
public void testJiraTest1182() throws java.lang.Exception
java.lang.Exception
public void testJiraTest52() throws java.lang.Exception
java.lang.Exception
public void testDuplicateVersions() throws java.lang.Exception
java.lang.Exception
public void testUpdates() throws java.lang.Exception
java.lang.Exception
public void testUpdatesWithMajorCompaction() throws java.lang.Exception
java.lang.Exception
public void testMajorCompactionBetweenTwoUpdates() throws java.lang.Exception
java.lang.Exception
public void testGet_EmptyTable() throws java.io.IOException
java.io.IOException
public void testGet_NullQualifier() throws java.io.IOException
java.io.IOException
public void testGet_NonExistentRow() throws java.io.IOException
java.io.IOException
public void testPut() throws java.io.IOException
java.io.IOException
public void testPutNoCF() throws java.io.IOException
java.io.IOException
public void testRowsPut() throws java.io.IOException
java.io.IOException
public void testRowsPutBufferedOneFlush() throws java.io.IOException
java.io.IOException
public void testRowsPutBufferedManyManyFlushes() throws java.io.IOException
java.io.IOException
public void testAddKeyValue() throws java.io.IOException
java.io.IOException
public void testHBase737() throws java.io.IOException
java.io.IOException
public void testListTables() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public void testUnmanagedHConnection() throws java.io.IOException
java.io.IOException
public void testUnmanagedHConnectionReconnect() throws java.lang.Exception
java.lang.Exception
public void testMiscHTableStuff() throws java.io.IOException
java.io.IOException
public void testGetClosestRowBefore() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public void testScanVariableReuse() throws java.lang.Exception
java.lang.Exception
public void testMultiRowMutation() throws java.lang.Exception
java.lang.Exception
public void testRowMutation() throws java.lang.Exception
java.lang.Exception
public void testAppend() throws java.lang.Exception
java.lang.Exception
public void testClientPoolRoundRobin() throws java.io.IOException
java.io.IOException
public void testClientPoolThreadLocal() throws java.io.IOException
java.io.IOException
public void testCheckAndPut() throws java.io.IOException
java.io.IOException
public void testCheckAndPutWithCompareOp() throws java.io.IOException
java.io.IOException
public void testCheckAndDeleteWithCompareOp() throws java.io.IOException
java.io.IOException
public void testScanMetrics() throws java.lang.Exception
java.lang.Exception
public void testCacheOnWriteEvictOnClose() throws java.lang.Exception
java.lang.Exception
public void testNonCachedGetRegionLocation() throws java.lang.Exception
java.lang.Exception
public void testGetRegionsInRange() throws java.lang.Exception
java.lang.Exception
public void testJira6912() throws java.lang.Exception
java.lang.Exception
public void testScan_NullQualifier() throws java.io.IOException
java.io.IOException
public void testNegativeTimestamp() throws java.io.IOException
java.io.IOException
public void testIllegalTableDescriptor() throws java.lang.Exception
java.lang.Exception
public void testRawScanRespectsVersions() throws java.lang.Exception
java.lang.Exception
public void testSmallScan() throws java.lang.Exception
java.lang.Exception
public void testSuperSimpleWithReverseScan() throws java.lang.Exception
java.lang.Exception
public void testFiltersWithReverseScan() throws java.lang.Exception
java.lang.Exception
public void testKeyOnlyFilterWithReverseScan() throws java.lang.Exception
java.lang.Exception
public void testSimpleMissingWithReverseScan() throws java.lang.Exception
java.lang.Exception
public void testNullWithReverseScan() throws java.lang.Exception
java.lang.Exception
public void testDeletesWithReverseScan() throws java.lang.Exception
java.lang.Exception
public void testReversedScanUnderMultiRegions() throws java.lang.Exception
java.lang.Exception
public void testSmallReversedScanUnderMultiRegions() throws java.lang.Exception
java.lang.Exception
public void testGetStartEndKeysWithRegionReplicas() throws java.io.IOException
java.io.IOException
public void testFilterAllRecords() throws java.io.IOException
java.io.IOException
public void testRegionCache() throws java.io.IOException
java.io.IOException