Package org.apache.hadoop.hbase.regionserver

Class TestCompactingMemStore

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestDefaultMemStore

org.apache.hadoop.hbase.regionserver.TestCompactingMemStore

Direct Known Subclasses:

TestCompactingToCellFlatMapMemStore

public class TestCompactingMemStore
extends TestDefaultMemStore

compacted memstore test case

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	TestCompactingMemStore.EnvironmentEdgeForMemstoreTest
protected static class	TestCompactingMemStore.MyCompactingMemStore

Field Summary

Fields

Modifier and Type	Field	Description
protected static org.apache.hadoop.hbase.regionserver.ChunkCreator	chunkCreator
static final HBaseClassTestRule	CLASS_RULE
private static final org.slf4j.Logger	LOG
protected org.apache.hadoop.hbase.regionserver.HRegion	region
protected org.apache.hadoop.hbase.regionserver.RegionServicesForStores	regionServicesForStores
protected org.apache.hadoop.hbase.regionserver.HStore	store

Fields inherited from class org.apache.hadoop.hbase.regionserver.TestDefaultMemStore

FAMILY, memstore, mvcc, name, QUALIFIER_COUNT, ROW_COUNT, startSeqNum

Constructor Summary

Constructors

Constructor	Description
TestCompactingMemStore()

Method Summary

Modifier and Type	Method	Description
protected int	addRowsByKeys(org.apache.hadoop.hbase.regionserver.AbstractMemStore hmc, String[] keys)
protected int	addRowsByKeys(org.apache.hadoop.hbase.regionserver.AbstractMemStore hmc, String[] keys, byte[] val)
protected void	compactingSetUp()
private void	isExpectedRowWithoutTimestamps(int rowIndex, List<org.apache.hadoop.hbase.Cell> kvs)
protected static byte[]	makeQualifier(int i1, int i2)
private long	runSnapshot(org.apache.hadoop.hbase.regionserver.AbstractMemStore hmc, boolean useForce)
void	setUp()
void	tearDown()
void	testCompaction1Bucket()
void	testCompaction2Buckets()
void	testCompaction3Buckets()
void	testGet_memstoreAndSnapShot()
void	testGetNextRow()	Test getNextRow from memstore
void	testMagicCompaction3Buckets()
void	testPuttingBackChunksAfterFlushing()
void	testPuttingBackChunksWithOpeningPipelineScanner()
void	testPuttingBackChunksWithOpeningScanner()
void	testScanAcrossSnapshot2()	A simple test which verifies the 3 possible states when scanning across snapshot.
void	testSnapshotting()	Test memstore snapshots
void	testTimeOfOldestEdit()	A simple test which flush in memory affect timeOfOldestEdit
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.

Methods inherited from class org.apache.hadoop.hbase.regionserver.TestDefaultMemStore

addRows, addRows, assertScannerResults, checkShouldFlush, doScan, internalSetUp, main, tearDownClass, testBytesReadFromMemstore, testBytesReadFromMemstoreWithScanMetricsDisabled, testGetWithDelete, testGetWithDeleteColumn, testGetWithDeleteFamily, testKeepDeleteInmemstore, testMemstoreConcurrentControl, testMemstoreDeletesVisibilityWithSameKey, testMemstoreEditsVisibilityWithSameKey, testMultipleVersionsSimple, testPutSameCell, testPutSameKey, testReadOwnWritesUnderConcurrency, testRetainsDeleteColumn, testRetainsDeleteFamily, testRetainsDeleteVersion, testScanAcrossSnapshot, testShouldFlush, testShouldFlushMeta, verifyOneScanAcrossSnapshot2, verifyScanAcrossSnapshot2

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

chunkCreator

protected static org.apache.hadoop.hbase.regionserver.ChunkCreator chunkCreator

region

protected org.apache.hadoop.hbase.regionserver.HRegion region

regionServicesForStores

protected org.apache.hadoop.hbase.regionserver.RegionServicesForStores regionServicesForStores

store

protected org.apache.hadoop.hbase.regionserver.HStore store

Constructor Details

TestCompactingMemStore

public TestCompactingMemStore()

Method Details

makeQualifier

protected static byte[] makeQualifier(int i1,
 int i2)

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

setUp

public void setUp()
           throws Exception

Overrides:

setUp in class TestDefaultMemStore

Throws:

Exception

compactingSetUp

protected void compactingSetUp()
                        throws Exception

Throws:

Exception

testTimeOfOldestEdit

public void testTimeOfOldestEdit()

A simple test which flush in memory affect timeOfOldestEdit

testScanAcrossSnapshot2

public void testScanAcrossSnapshot2()
                             throws IOException,
CloneNotSupportedException

A simple test which verifies the 3 possible states when scanning across snapshot.

Overrides:

testScanAcrossSnapshot2 in class TestDefaultMemStore

Throws:

IOException

CloneNotSupportedException

testSnapshotting

public void testSnapshotting()
                      throws IOException

Test memstore snapshots

Overrides:

testSnapshotting in class TestDefaultMemStore

Throws:

IOException

testGetNextRow

public void testGetNextRow()
                    throws Exception

Test getNextRow from memstore

Overrides:

testGetNextRow in class TestDefaultMemStore

Throws:

Exception

testGet_memstoreAndSnapShot

public void testGet_memstoreAndSnapShot()
                                 throws IOException

Overrides:

testGet_memstoreAndSnapShot in class TestDefaultMemStore

Throws:

IOException

testUpsertMemstoreSize

public void testUpsertMemstoreSize()
                            throws Exception

Add keyvalues with a fixed memstoreTs, and checks that memstore size is decreased as older keyvalues are deleted from the memstore.

Overrides:

testUpsertMemstoreSize in class TestDefaultMemStore

Throws:

Exception

testUpdateToTimeOfOldestEdit

public void testUpdateToTimeOfOldestEdit()
                                  throws Exception

Tests that the timeOfOldestEdit is updated correctly for the various edit operations in memstore.

Overrides:

testUpdateToTimeOfOldestEdit in class TestDefaultMemStore

Throws:

Exception

runSnapshot

private long runSnapshot(org.apache.hadoop.hbase.regionserver.AbstractMemStore hmc,
 boolean useForce)
                  throws IOException

Throws:

IOException

isExpectedRowWithoutTimestamps

private void isExpectedRowWithoutTimestamps(int rowIndex,
 List<org.apache.hadoop.hbase.Cell> kvs)

testPuttingBackChunksAfterFlushing

public void testPuttingBackChunksAfterFlushing()
                                        throws IOException

Throws:

IOException

testPuttingBackChunksWithOpeningScanner

public void testPuttingBackChunksWithOpeningScanner()
                                             throws IOException

Throws:

IOException

testPuttingBackChunksWithOpeningPipelineScanner

public void testPuttingBackChunksWithOpeningPipelineScanner()
                                                     throws IOException

Throws:

IOException

testCompaction1Bucket

public void testCompaction1Bucket()
                           throws IOException

Throws:

IOException

testCompaction2Buckets

public void testCompaction2Buckets()
                            throws IOException

Throws:

IOException

testCompaction3Buckets

public void testCompaction3Buckets()
                            throws IOException

Throws:

IOException

testMagicCompaction3Buckets

public void testMagicCompaction3Buckets()
                                 throws IOException

Throws:

IOException

addRowsByKeys

protected int addRowsByKeys(org.apache.hadoop.hbase.regionserver.AbstractMemStore hmc,
 String[] keys)

addRowsByKeys

protected int addRowsByKeys(org.apache.hadoop.hbase.regionserver.AbstractMemStore hmc,
 String[] keys,
 byte[] val)