org.apache.hadoop.hbase.regionserver

Class TestPerColumnFamilyFlush

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestPerColumnFamilyFlush

public class TestPerColumnFamilyFlush
extends java.lang.Object

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

Field Summary

Fields

Modifier and Type	Field and Description
static byte[][]	FAMILIES
static byte[]	FAMILY1
static byte[]	FAMILY2
static byte[]	FAMILY3
static TableName	TABLENAME

Constructor Summary

Constructors

Constructor and Description
TestPerColumnFamilyFlush()

Method Summary

Modifier and Type	Method and Description
static void	main(java.lang.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	testLogReplayWithDistributedReplay()
void	testSelectiveFlushWhenEnabled()
void	testSelectiveFlushWhenNotEnabled()

Methods inherited from class java.lang.Object

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

Field Detail

TABLENAME

public static final 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

testSelectiveFlushWhenEnabled

public void testSelectiveFlushWhenEnabled()
                                   throws java.io.IOException

Throws:

java.io.IOException

testSelectiveFlushWhenNotEnabled

public void testSelectiveFlushWhenNotEnabled()
                                      throws java.io.IOException

Throws:

java.io.IOException

testLogReplayWithDistributedReplay

public void testLogReplayWithDistributedReplay()
                                        throws java.lang.Exception

Throws:

java.lang.Exception

testLogReplayWithDistributedLogSplit

public void testLogReplayWithDistributedLogSplit()
                                          throws java.lang.Exception

Throws:

java.lang.Exception

testFlushingWhenLogRolling

public void testFlushingWhenLogRolling()
                                throws java.lang.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.

Throws:

java.io.IOException

java.lang.Exception

testCompareStoreFileCount

public void testCompareStoreFileCount()
                               throws java.lang.Exception

Throws:

java.lang.Exception

main

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

Throws:

java.lang.Exception