Package org.apache.hadoop.hbase.regionserver

Class TestWalAndCompactingMemStoreFlush

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestWalAndCompactingMemStoreFlush

public class TestWalAndCompactingMemStoreFlush
extends Object

This test verifies the correctness of the Per Column Family flushing strategy when part of the memstores are compacted memstores

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	TestWalAndCompactingMemStoreFlush.ConcurrentPutRunnable	The in-memory-flusher thread performs the flush asynchronously.

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.conf.Configuration	conf
private static final org.apache.hadoop.fs.Path	DIR
static final byte[][]	FAMILIES
static final byte[]	FAMILY1
static final byte[]	FAMILY2
static final byte[]	FAMILY3
static final org.apache.hadoop.hbase.TableName	TABLENAME
private static final HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestWalAndCompactingMemStoreFlush()

Method Summary

Modifier and Type	Method	Description
private org.apache.hadoop.hbase.client.Put	createDoublePut(int familyNum, int putNum)
private org.apache.hadoop.hbase.client.Put	createPut(int familyNum, int putNum)
private org.apache.hadoop.hbase.wal.WAL	getWAL(org.apache.hadoop.hbase.regionserver.Region region)
private org.apache.hadoop.hbase.regionserver.HRegion	initHRegion(String callingMethod, org.apache.hadoop.conf.Configuration conf)
void	setup()
void	testSelectiveFlushAndWALinDataCompaction()
void	testSelectiveFlushWithBasicAndMerge()
void	testSelectiveFlushWithEager()
void	testSelectiveFlushWithIndexCompaction()
void	testStressFlushAndWALinIndexCompaction()
private void	verifyInMemoryFlushSize(org.apache.hadoop.hbase.regionserver.Region region)

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

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

DIR

private static final org.apache.hadoop.fs.Path DIR

TABLENAME

public static final org.apache.hadoop.hbase.TableName TABLENAME

FAMILIES

public static final byte[][] FAMILIES

FAMILY1

public static final byte[] FAMILY1

FAMILY2

public static final byte[] FAMILY2

FAMILY3

public static final byte[] FAMILY3

conf

private org.apache.hadoop.conf.Configuration conf

Constructor Details

TestWalAndCompactingMemStoreFlush

public TestWalAndCompactingMemStoreFlush()

Method Details

initHRegion

private org.apache.hadoop.hbase.regionserver.HRegion initHRegion(String callingMethod,
 org.apache.hadoop.conf.Configuration conf)
                                                          throws IOException

Throws:

IOException

createPut

private org.apache.hadoop.hbase.client.Put createPut(int familyNum,
 int putNum)

createDoublePut

private org.apache.hadoop.hbase.client.Put createDoublePut(int familyNum,
 int putNum)

verifyInMemoryFlushSize

private void verifyInMemoryFlushSize(org.apache.hadoop.hbase.regionserver.Region region)

setup

public void setup()

testSelectiveFlushWithEager

public void testSelectiveFlushWithEager()
                                 throws IOException

Throws:

IOException

testSelectiveFlushWithIndexCompaction

public void testSelectiveFlushWithIndexCompaction()
                                           throws IOException

Throws:

IOException

testSelectiveFlushAndWALinDataCompaction

public void testSelectiveFlushAndWALinDataCompaction()
                                              throws IOException

Throws:

IOException

testSelectiveFlushWithBasicAndMerge

public void testSelectiveFlushWithBasicAndMerge()
                                         throws IOException

Throws:

IOException

testStressFlushAndWALinIndexCompaction

public void testStressFlushAndWALinIndexCompaction()
                                            throws IOException

Throws:

IOException

getWAL

private org.apache.hadoop.hbase.wal.WAL getWAL(org.apache.hadoop.hbase.regionserver.Region region)