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.Exception
public void testPutSameKey()
public void testScanAcrossSnapshot() throws java.io.IOException
java.io.IOException
public void testScanAcrossSnapshot2() throws java.io.IOException, java.lang.CloneNotSupportedException
java.io.IOException
java.lang.CloneNotSupportedException
public void testMemstoreConcurrentControl() throws java.io.IOException
java.io.IOException
public void testMemstoreEditsVisibilityWithSameKey() throws java.io.IOException
java.io.IOException
public void testMemstoreDeletesVisibilityWithSameKey() throws java.io.IOException
java.io.IOException
public void testReadOwnWritesUnderConcurrency() throws java.lang.Throwable
java.lang.Throwable
public void testSnapshotting() throws java.io.IOException
java.io.IOException
public void testMultipleVersionsSimple() throws java.lang.Exception
java.lang.Exception
public void testGetNextRow() throws java.lang.Exception
java.lang.InterruptedException
java.lang.Exception
public void testGet_memstoreAndSnapShot() throws java.io.IOException
java.io.IOException
public void testGetWithDelete() throws java.io.IOException
java.io.IOException
public void testGetWithDeleteColumn() throws java.io.IOException
java.io.IOException
public void testGetWithDeleteFamily() throws java.io.IOException
java.io.IOException
public void testKeepDeleteInmemstore()
public void testRetainsDeleteVersion() throws java.io.IOException
java.io.IOException
public void testRetainsDeleteColumn() throws java.io.IOException
java.io.IOException
public void testRetainsDeleteFamily() throws java.io.IOException
java.io.IOException
public void testMultipleTimestamps() throws java.io.IOException
java.io.IOException
public void testUpsertMSLAB() throws java.lang.Exception
java.lang.Exception
public void testUpsertMemstoreSize() throws java.lang.Exception
java.lang.Exception
public void testUpdateToTimeOfOldestEdit() throws java.lang.Exception
java.lang.Exception
public void testShouldFlush() throws java.lang.Exception
java.lang.Exception
public void testShouldFlushMeta() throws java.lang.Exception
java.lang.Exception
public static void main(java.lang.String[] args) throws java.io.IOException
java.io.IOException