org.apache.hadoop.hbase.regionserver

Class TestPerColumnFamilyFlush

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestPerColumnFamilyFlush

public class TestPerColumnFamilyFlush
extends Object

This test verifies the correctness of the Per Column Family flushing strategy

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
TestPerColumnFamilyFlush()

Method Summary

Modifier and Type	Method and Description
private org.apache.hadoop.hbase.client.Get	createGet(int familyNum, int putNum)
private org.apache.hadoop.hbase.client.Put	createPut(int familyNum, int putNum)
private void	doPut(org.apache.hadoop.hbase.client.Table table, long memstoreFlushSize)
private void	doTestLogReplay()
private int	getNumRolledLogFiles(org.apache.hadoop.hbase.regionserver.Region region)
private static org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.regionserver.HRegion,org.apache.hadoop.hbase.regionserver.HRegionServer>	getRegionWithName(org.apache.hadoop.hbase.TableName tableName)
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)
static void	main(String[] args)
void	testCompareStoreFileCount()
void	testFlushingWhenLogRolling() When a log roll is about to happen, we do a flush of the regions who will be affected by the log roll.
void	testLogReplayWithDistributedLogSplit()
void	testSelectiveFlushWhenEnabled()
void	testSelectiveFlushWhenNotEnabled()
(package private) void	verifyEdit(int familyNum, int putNum, org.apache.hadoop.hbase.client.Table table)

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

LOG

private static final org.slf4j.Logger LOG

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

Constructor Detail

TestPerColumnFamilyFlush

public TestPerColumnFamilyFlush()

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)

createGet

private org.apache.hadoop.hbase.client.Get createGet(int familyNum,
                                                     int putNum)

verifyEdit

void verifyEdit(int familyNum,
                int putNum,
                org.apache.hadoop.hbase.client.Table table)
         throws IOException

Throws:

IOException

testSelectiveFlushWhenEnabled

public void testSelectiveFlushWhenEnabled()
                                   throws IOException

Throws:

IOException

testSelectiveFlushWhenNotEnabled

public void testSelectiveFlushWhenNotEnabled()
                                      throws IOException

Throws:

IOException

getRegionWithName

private static org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.regionserver.HRegion,org.apache.hadoop.hbase.regionserver.HRegionServer> getRegionWithName(org.apache.hadoop.hbase.TableName tableName)

doTestLogReplay

private void doTestLogReplay()
                      throws Exception

Throws:

Exception

testLogReplayWithDistributedLogSplit

public void testLogReplayWithDistributedLogSplit()
                                          throws Exception

Throws:

Exception

getWAL

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

getNumRolledLogFiles

private int getNumRolledLogFiles(org.apache.hadoop.hbase.regionserver.Region region)

testFlushingWhenLogRolling

public void testFlushingWhenLogRolling()
                                throws Exception

When a log roll is about to happen, we do a flush of the regions who will be affected by the log roll. These flushes cannot be a selective flushes, otherwise we cannot roll the logs. This test ensures that we do a full-flush in that scenario. n

Throws:

Exception

doPut

private void doPut(org.apache.hadoop.hbase.client.Table table,
                   long memstoreFlushSize)
            throws IOException,
                   InterruptedException

Throws:

IOException

InterruptedException

testCompareStoreFileCount

public void testCompareStoreFileCount()
                               throws Exception

Throws:

Exception

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception