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 and Description
private class	TestWalAndCompactingMemStoreFlush.ConcurrentPutRunnable The in-memory-flusher thread performs the flush asynchronously.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
TestWalAndCompactingMemStoreFlush()

Method Summary

Modifier and Type	Method and 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 Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

TEST_UTIL

private static final HBaseTestingUtility 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 Detail

TestWalAndCompactingMemStoreFlush

public TestWalAndCompactingMemStoreFlush()

Method Detail

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)