org.apache.hadoop.hbase.regionserver

Class TestCompactionState

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestCompactionState

public class TestCompactionState
extends Object

Unit tests to test retrieving table/region compaction state

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	TestCompactionState.StateSource

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static org.slf4j.Logger	LOG
org.junit.rules.TestName	name
private static Random	random
private static HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
TestCompactionState()

Method Summary

Modifier and Type	Method and Description
private void	compaction(String tableName, int flushes, org.apache.hadoop.hbase.client.CompactionState expectedState, boolean singleFamily, TestCompactionState.StateSource stateSource) Load data to a table, flush it to disk, trigger compaction, confirm the compaction state is right and wait till it is done.
private static int	countStoreFilesInFamilies(List<org.apache.hadoop.hbase.regionserver.HRegion> regions, byte[][] families)
private static int	countStoreFilesInFamily(List<org.apache.hadoop.hbase.regionserver.HRegion> regions, byte[] family)
private static org.apache.hadoop.hbase.client.CompactionState	getCompactionState(TestCompactionState.StateSource stateSource, org.apache.hadoop.hbase.master.HMaster master, org.apache.hadoop.hbase.client.Admin admin, org.apache.hadoop.hbase.TableName table)
private static void	loadData(org.apache.hadoop.hbase.client.Table ht, byte[][] families, int rows, int flushes)
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testInvalidColumnFamily()
void	testMajorCompactionOnFamilyStateFromAdmin()
void	testMajorCompactionOnFamilyStateFromMaster()
void	testMajorCompactionStateFromAdmin()
void	testMajorCompactionStateFromMaster()
void	testMinorCompactionOnFamilyStateFromAdmin()
void	testMinorCompactionOnFamilyStateFromMaster()
void	testMinorCompactionStateFromAdmin()
void	testMinorCompactionStateFromMaster()

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

random

private static final Random random

name

public org.junit.rules.TestName name

Constructor Detail

TestCompactionState

public TestCompactionState()

Method Detail

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testMajorCompactionStateFromAdmin

public void testMajorCompactionStateFromAdmin()
                                       throws IOException,
                                              InterruptedException

Throws:

IOException

InterruptedException

testMinorCompactionStateFromAdmin

public void testMinorCompactionStateFromAdmin()
                                       throws IOException,
                                              InterruptedException

Throws:

IOException

InterruptedException

testMajorCompactionOnFamilyStateFromAdmin

public void testMajorCompactionOnFamilyStateFromAdmin()
                                               throws IOException,
                                                      InterruptedException

Throws:

IOException

InterruptedException

testMinorCompactionOnFamilyStateFromAdmin

public void testMinorCompactionOnFamilyStateFromAdmin()
                                               throws IOException,
                                                      InterruptedException

Throws:

IOException

InterruptedException

testMajorCompactionStateFromMaster

public void testMajorCompactionStateFromMaster()
                                        throws IOException,
                                               InterruptedException

Throws:

IOException

InterruptedException

testMinorCompactionStateFromMaster

public void testMinorCompactionStateFromMaster()
                                        throws IOException,
                                               InterruptedException

Throws:

IOException

InterruptedException

testMajorCompactionOnFamilyStateFromMaster

public void testMajorCompactionOnFamilyStateFromMaster()
                                                throws IOException,
                                                       InterruptedException

Throws:

IOException

InterruptedException

testMinorCompactionOnFamilyStateFromMaster

public void testMinorCompactionOnFamilyStateFromMaster()
                                                throws IOException,
                                                       InterruptedException

Throws:

IOException

InterruptedException

testInvalidColumnFamily

public void testInvalidColumnFamily()
                             throws IOException,
                                    InterruptedException

Throws:

IOException

InterruptedException

compaction

private void compaction(String tableName,
                        int flushes,
                        org.apache.hadoop.hbase.client.CompactionState expectedState,
                        boolean singleFamily,
                        TestCompactionState.StateSource stateSource)
                 throws IOException,
                        InterruptedException

Load data to a table, flush it to disk, trigger compaction, confirm the compaction state is right and wait till it is done.

Parameters:

tableName -

flushes -

expectedState -

singleFamily - otherwise, run compaction on all cfs

stateSource - get the state by Admin or Master

Throws:

IOException

InterruptedException

getCompactionState

private static org.apache.hadoop.hbase.client.CompactionState getCompactionState(TestCompactionState.StateSource stateSource,
                                                                                 org.apache.hadoop.hbase.master.HMaster master,
                                                                                 org.apache.hadoop.hbase.client.Admin admin,
                                                                                 org.apache.hadoop.hbase.TableName table)
                                                                          throws IOException

Throws:

IOException

countStoreFilesInFamily

private static int countStoreFilesInFamily(List<org.apache.hadoop.hbase.regionserver.HRegion> regions,
                                           byte[] family)

countStoreFilesInFamilies

private static int countStoreFilesInFamilies(List<org.apache.hadoop.hbase.regionserver.HRegion> regions,
                                             byte[][] families)

loadData

private static void loadData(org.apache.hadoop.hbase.client.Table ht,
                             byte[][] families,
                             int rows,
                             int flushes)
                      throws IOException

Throws:

IOException