public class TestDefaultMemStore
extends TestCase
| Constructor and Description |
|---|
TestDefaultMemStore() |
| Modifier and Type | Method and Description |
|---|---|
static void |
main(java.lang.String[] args) |
void |
setUp() |
void |
testGet_memstoreAndSnapShot() |
void |
testGetNextRow()
Test getNextRow from memstore
|
void |
testGetWithDelete() |
void |
testGetWithDeleteColumn() |
void |
testGetWithDeleteFamily() |
void |
testKeepDeleteInmemstore() |
void |
testMemstoreConcurrentControl() |
void |
testMemstoreDeletesVisibilityWithSameKey()
When we insert a higher-memstoreTS deletion of a cell but with
the same timestamp, we still need to provide consistent reads
for the same scanner.
|
void |
testMemstoreEditsVisibilityWithSameKey()
Regression test for HBASE-2616, HBASE-2670.
|
void |
testMultipleTimestamps()
Test to ensure correctness when using Memstore with multiple timestamps
|
void |
testMultipleVersionsSimple() |
void |
testPutSameKey() |
void |
testReadOwnWritesUnderConcurrency() |
void |
testRetainsDeleteColumn() |
void |
testRetainsDeleteFamily() |
void |
testRetainsDeleteVersion() |
void |
testScanAcrossSnapshot()
Test memstore snapshot happening while scanning.
|
void |
testScanAcrossSnapshot2()
A simple test which verifies the 3 possible states when scanning across snapshot.
|
void |
testShouldFlush()
Tests the HRegion.shouldFlush method - adds an edit in the memstore
and checks that shouldFlush returns true, and another where it disables
the periodic flush functionality and tests whether shouldFlush returns
false.
|
void |
testShouldFlushMeta() |
void |
testSnapshotting()
Test memstore snapshots
|
void |
testUpdateToTimeOfOldestEdit()
Tests that the timeOfOldestEdit is updated correctly for the
various edit operations in memstore.
|
void |
testUpsertMemstoreSize()
Add keyvalues with a fixed memstoreTs, and checks that memstore size is decreased
as older keyvalues are deleted from the memstore.
|
void |
testUpsertMSLAB()
Test a pathological pattern that shows why we can't currently
use the MSLAB for upsert workloads.
|
public void setUp()
throws java.lang.Exception
java.lang.Exceptionpublic void testPutSameKey()
public void testScanAcrossSnapshot()
throws java.io.IOException
java.io.IOExceptionpublic void testScanAcrossSnapshot2()
throws java.io.IOException,
java.lang.CloneNotSupportedException
java.io.IOExceptionjava.lang.CloneNotSupportedExceptionpublic void testMemstoreConcurrentControl()
throws java.io.IOException
java.io.IOExceptionpublic void testMemstoreEditsVisibilityWithSameKey()
throws java.io.IOException
java.io.IOExceptionpublic void testMemstoreDeletesVisibilityWithSameKey()
throws java.io.IOException
java.io.IOExceptionpublic void testReadOwnWritesUnderConcurrency()
throws java.lang.Throwable
java.lang.Throwablepublic void testSnapshotting()
throws java.io.IOException
java.io.IOExceptionpublic void testMultipleVersionsSimple()
throws java.lang.Exception
java.lang.Exceptionpublic void testGetNextRow()
throws java.lang.Exception
java.lang.InterruptedExceptionjava.lang.Exceptionpublic void testGet_memstoreAndSnapShot()
throws java.io.IOException
java.io.IOExceptionpublic void testGetWithDelete()
throws java.io.IOException
java.io.IOExceptionpublic void testGetWithDeleteColumn()
throws java.io.IOException
java.io.IOExceptionpublic void testGetWithDeleteFamily()
throws java.io.IOException
java.io.IOExceptionpublic void testKeepDeleteInmemstore()
public void testRetainsDeleteVersion()
throws java.io.IOException
java.io.IOExceptionpublic void testRetainsDeleteColumn()
throws java.io.IOException
java.io.IOExceptionpublic void testRetainsDeleteFamily()
throws java.io.IOException
java.io.IOExceptionpublic void testMultipleTimestamps()
throws java.io.IOException
java.io.IOExceptionpublic void testUpsertMSLAB()
throws java.lang.Exception
java.lang.Exceptionpublic void testUpsertMemstoreSize()
throws java.lang.Exception
java.lang.Exceptionpublic void testUpdateToTimeOfOldestEdit()
throws java.lang.Exception
java.lang.Exceptionpublic void testShouldFlush()
throws java.lang.Exception
java.lang.Exceptionpublic void testShouldFlushMeta()
throws java.lang.Exception
java.lang.Exceptionpublic static void main(java.lang.String[] args)
throws java.io.IOException
java.io.IOException