public class TestHRegion
extends java.lang.Object
| Modifier and Type | Class and Description |
|---|---|
protected class |
TestHRegion.FlushThread |
protected class |
TestHRegion.PutThread |
| Modifier and Type | Field and Description |
|---|---|
static Configuration |
CONF |
protected java.lang.String |
method |
protected MetricsAssertHelper |
metricsAssertHelper |
TestName |
name |
protected byte[] |
qual1 |
protected byte[] |
qual2 |
protected byte[] |
qual3 |
protected byte[] |
row |
protected byte[] |
row2 |
protected byte[] |
tableName |
protected byte[] |
value1 |
protected byte[] |
value2 |
| Constructor and Description |
|---|
TestHRegion() |
public TestName name
public static Configuration CONF
protected byte[] tableName
protected java.lang.String method
protected final byte[] qual1
protected final byte[] qual2
protected final byte[] qual3
protected final byte[] value1
protected final byte[] value2
protected final byte[] row
protected final byte[] row2
protected final MetricsAssertHelper metricsAssertHelper
public void setup()
throws java.io.IOException
java.io.IOExceptionpublic void tearDown()
throws java.lang.Exception
java.lang.Exceptionpublic void testCloseCarryingSnapshot()
throws java.io.IOException
java.io.IOExceptionpublic void testMemstoreSnapshotSize()
throws java.io.IOException
java.io.IOExceptionpublic void testMemstoreSizeWithFlushCanceling()
throws java.io.IOException
java.io.IOExceptionpublic void testMemstoreSizeAccountingWithFailedPostBatchMutate()
throws java.io.IOException
java.io.IOExceptionpublic void testFlushSizeAccounting()
throws java.lang.Exception
java.lang.Exceptionpublic void testCloseWithFailingFlush()
throws java.lang.Exception
java.lang.Exceptionpublic void testCompactionAffectedByScanners()
throws java.lang.Exception
java.lang.Exceptionpublic void testToShowNPEOnRegionScannerReseek()
throws java.lang.Exception
java.lang.Exceptionpublic void testSkipRecoveredEditsReplay()
throws java.lang.Exception
java.lang.Exceptionpublic void testSkipRecoveredEditsReplaySomeIgnored()
throws java.lang.Exception
java.lang.Exceptionpublic void testSkipRecoveredEditsReplayAllIgnored()
throws java.lang.Exception
java.lang.Exceptionpublic void testSkipRecoveredEditsReplayTheLastFileIgnored()
throws java.lang.Exception
java.lang.Exceptionpublic void testRecoveredEditsReplayCompaction()
throws java.lang.Exception
java.lang.Exceptionpublic void testRecoveredEditsReplayCompaction(boolean mismatchedRegionName)
throws java.lang.Exception
java.lang.Exceptionpublic void testFlushMarkers()
throws java.lang.Exception
java.lang.Exceptionpublic void testFlushMarkersWALFail()
throws java.lang.Exception
java.lang.Exceptionpublic void testGetWhileRegionClose()
throws java.io.IOException
java.io.IOExceptionpublic void testWeirdCacheBehaviour()
throws java.lang.Exception
java.lang.Exceptionpublic void testAppendWithReadOnlyTable()
throws java.lang.Exception
java.lang.Exceptionpublic void testIncrWithReadOnlyTable()
throws java.lang.Exception
java.lang.Exceptionpublic void testFamilyWithAndWithoutColon()
throws java.lang.Exception
java.lang.Exceptionpublic void testBatchPut_whileNoRowLocksHeld()
throws java.io.IOException
java.io.IOExceptionpublic void testBatchPut_whileMultipleRowLocksHeld()
throws java.lang.Exception
java.lang.Exceptionpublic void testBatchPutWithTsSlop()
throws java.lang.Exception
java.lang.Exceptionpublic void testCheckAndMutate_WithEmptyRowValue()
throws java.io.IOException
java.io.IOExceptionpublic void testCheckAndMutate_WithWrongValue()
throws java.io.IOException
java.io.IOExceptionpublic void testCheckAndMutate_WithCorrectValue()
throws java.io.IOException
java.io.IOExceptionpublic void testCheckAndMutate_WithNonEqualCompareOp()
throws java.io.IOException
java.io.IOExceptionpublic void testCheckAndPut_ThatPutWasWritten()
throws java.io.IOException
java.io.IOExceptionpublic void testCheckAndPut_wrongRowInPut()
throws java.io.IOException
java.io.IOExceptionpublic void testCheckAndDelete_ThatDeleteWasWritten()
throws java.io.IOException
java.io.IOExceptionpublic void testDelete_multiDeleteColumn()
throws java.io.IOException
java.io.IOExceptionpublic void testDelete_CheckFamily()
throws java.io.IOException
java.io.IOExceptionpublic void testDelete_mixed()
throws java.io.IOException,
java.lang.InterruptedException
java.io.IOExceptionjava.lang.InterruptedExceptionpublic void testDeleteRowWithFutureTs()
throws java.io.IOException
java.io.IOExceptionpublic void testPutWithLatestTS()
throws java.io.IOException
java.io.IOExceptionpublic void testPutWithTsSlop()
throws java.io.IOException
java.io.IOExceptionpublic void testScanner_DeleteOneFamilyNotAnother()
throws java.io.IOException
java.io.IOExceptionpublic void testDeleteColumns_PostInsert()
throws java.io.IOException,
java.lang.InterruptedException
java.io.IOExceptionjava.lang.InterruptedExceptionpublic void testDeleteFamily_PostInsert()
throws java.io.IOException,
java.lang.InterruptedException
java.io.IOExceptionjava.lang.InterruptedExceptionpublic void doTestDelete_AndPostInsert(Delete delete) throws java.io.IOException, java.lang.InterruptedException
java.io.IOExceptionjava.lang.InterruptedExceptionpublic void testDelete_CheckTimestampUpdated()
throws java.io.IOException
java.io.IOExceptionpublic void testGet_FamilyChecker()
throws java.io.IOException
java.io.IOExceptionpublic void testGet_Basic()
throws java.io.IOException
java.io.IOExceptionpublic void testGet_Empty()
throws java.io.IOException
java.io.IOExceptionpublic void testMerge()
throws java.io.IOException
java.io.IOExceptionpublic void testGetScanner_WithOkFamilies()
throws java.io.IOException
java.io.IOExceptionpublic void testGetScanner_WithNotOkFamilies()
throws java.io.IOException
java.io.IOExceptionpublic void testGetScanner_WithNoFamilies()
throws java.io.IOException
java.io.IOExceptionpublic void testGetScanner_WithRegionClosed()
throws java.io.IOException
java.io.IOExceptionpublic void testRegionScanner_Next()
throws java.io.IOException
java.io.IOExceptionpublic void testScanner_ExplicitColumns_FromMemStore_EnforceVersions()
throws java.io.IOException
java.io.IOExceptionpublic void testScanner_ExplicitColumns_FromFilesOnly_EnforceVersions()
throws java.io.IOException
java.io.IOExceptionpublic void testScanner_ExplicitColumns_FromMemStoreAndFiles_EnforceVersions()
throws java.io.IOException
java.io.IOExceptionpublic void testScanner_Wildcard_FromMemStore_EnforceVersions()
throws java.io.IOException
java.io.IOExceptionpublic void testScanner_Wildcard_FromFilesOnly_EnforceVersions()
throws java.io.IOException
java.io.IOExceptionpublic void testScanner_StopRow1542()
throws java.io.IOException
java.io.IOExceptionpublic void testScanner_Wildcard_FromMemStoreAndFiles_EnforceVersions()
throws java.io.IOException
java.io.IOExceptionpublic void testScanner_JoinedScanners()
throws java.io.IOException
java.io.IOExceptionpublic void testScanner_JoinedScannersWithLimits()
throws java.io.IOException
java.io.IOExceptionpublic void testLongQualifier()
throws java.lang.Exception
java.lang.Exceptionpublic void testBasicSplit()
throws java.lang.Exception
java.lang.Exceptionpublic void testSplitRegion()
throws java.io.IOException
java.io.IOExceptionpublic void testClearForceSplit()
throws java.io.IOException
java.io.IOExceptionpublic void testFlushCacheWhileScanning()
throws java.io.IOException,
java.lang.InterruptedException
java.io.IOException - scan / compactjava.lang.InterruptedException - thread joinpublic void testWritesWhileScanning()
throws java.io.IOException,
java.lang.InterruptedException
java.io.IOException - by flush / scan / compactionjava.lang.InterruptedException - when joining threadspublic void testWritesWhileGetting()
throws java.lang.Exception
java.io.IOException - by flush / scan / compactionjava.lang.InterruptedException - when joining threadsjava.lang.Exceptionpublic void testHolesInMeta()
throws java.lang.Exception
java.lang.Exceptionpublic void testIndexesScanWithOneDeletedRow()
throws java.io.IOException
java.io.IOExceptionpublic void testBloomFilterSize()
throws java.io.IOException
java.io.IOExceptionpublic void testAllColumnsWithBloomFilter()
throws java.io.IOException
java.io.IOExceptionpublic void testDeleteRowWithBloomFilter()
throws java.io.IOException
java.io.IOExceptionpublic void testgetHDFSBlocksDistribution()
throws java.lang.Exception
java.lang.Exceptionpublic void testStatusSettingToAbortIfAnyExceptionDuringRegionInitilization()
throws java.lang.Exception
java.lang.Exceptionpublic void testRegionInfoFileCreation()
throws java.io.IOException
java.io.IOExceptionpublic void testParallelIncrementWithMemStoreFlush()
throws java.lang.Exception
java.lang.Exceptionpublic void testParallelAppendWithMemStoreFlush()
throws java.lang.Exception
java.lang.Exceptionpublic void testPutWithMemStoreFlush()
throws java.lang.Exception
java.lang.Exceptionpublic void testDurability()
throws java.lang.Exception
java.lang.Exceptionpublic void testRegionReplicaSecondary()
throws java.io.IOException
java.io.IOExceptionpublic void testRegionReplicaSecondaryIsReadOnly()
throws java.io.IOException
java.io.IOExceptionpublic void testCompactionFromPrimary()
throws java.io.IOException
java.io.IOExceptionpublic void testFlushResult()
throws java.io.IOException
java.io.IOExceptionpublic static HRegion initHRegion(TableName tableName, java.lang.String callingMethod, Configuration conf, byte[]... families) throws java.io.IOException
tableName - callingMethod - conf - families - HRegion.closeHRegion(HRegion) when done.java.io.IOExceptionpublic static HRegion initHRegion(byte[] tableName, java.lang.String callingMethod, Configuration conf, byte[]... families) throws java.io.IOException
tableName - callingMethod - conf - families - HRegion.closeHRegion(HRegion) when done.java.io.IOExceptionpublic static HRegion initHRegion(byte[] tableName, java.lang.String callingMethod, Configuration conf, boolean isReadOnly, byte[]... families) throws java.io.IOException
tableName - callingMethod - conf - isReadOnly - families - HRegion.closeHRegion(HRegion) when done.java.io.IOExceptionpublic static HRegion initHRegion(byte[] tableName, byte[] startKey, byte[] stopKey, java.lang.String callingMethod, Configuration conf, boolean isReadOnly, byte[]... families) throws java.io.IOException
java.io.IOExceptionpublic static HRegion initHRegion(byte[] tableName, byte[] startKey, byte[] stopKey, java.lang.String callingMethod, Configuration conf, boolean isReadOnly, Durability durability, WAL wal, byte[]... families) throws java.io.IOException
tableName - startKey - stopKey - callingMethod - conf - isReadOnly - families - HRegion.closeHRegion(HRegion) when done.java.io.IOExceptionpublic void testReverseScanner_FromMemStore_SingleCF_Normal()
throws java.io.IOException
java.io.IOExceptionpublic void testReverseScanner_FromMemStore_SingleCF_LargerKey()
throws java.io.IOException
java.io.IOExceptionpublic void testReverseScanner_FromMemStore_SingleCF_FullScan()
throws java.io.IOException
java.io.IOExceptionpublic void testReverseScanner_moreRowsMayExistAfter()
throws java.io.IOException
java.io.IOExceptionpublic void testReverseScanner_smaller_blocksize()
throws java.io.IOException
java.io.IOExceptionpublic void testReverseScanner_FromMemStoreAndHFiles_MultiCFs1()
throws java.io.IOException
java.io.IOExceptionpublic void testReverseScanner_FromMemStoreAndHFiles_MultiCFs2()
throws java.io.IOException
java.io.IOExceptionpublic void testReverseScanner_StackOverflow()
throws java.io.IOException
java.io.IOExceptionpublic void testSplitRegionWithReverseScan()
throws java.io.IOException
java.io.IOExceptionpublic void testWriteRequestsCounter()
throws java.io.IOException
java.io.IOExceptionpublic void testOpenRegionWrittenToWAL()
throws java.lang.Exception
java.lang.Exceptionpublic void testFlushedFileWithNoTags()
throws java.lang.Exception
java.lang.Exceptionpublic void testOpenRegionWrittenToWALForLogReplay()
throws java.lang.Exception
java.lang.Exceptionpublic void testCloseRegionWrittenToWAL()
throws java.lang.Exception
java.lang.Exceptionpublic void testRegionTooBusy()
throws java.io.IOException
java.io.IOExceptionpublic void testCellTTLs()
throws java.io.IOException
java.io.IOExceptionpublic void testIncrementTimestampsAreMonotonic()
throws java.io.IOException
java.io.IOExceptionpublic void testAppendTimestampsAreMonotonic()
throws java.io.IOException
java.io.IOExceptionpublic void testCheckAndMutateTimestampsAreMonotonic()
throws java.io.IOException
java.io.IOExceptionpublic void testBatchMutateWithWrongRegionException()
throws java.lang.Exception
java.lang.Exceptionpublic void testCheckAndRowMutateTimestampsAreMonotonic()
throws java.io.IOException
java.io.IOExceptionpublic void testWritesWhileRollWriter()
throws java.io.IOException
java.io.IOException - if IO error occurred during test