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

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) 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 void	loadData(org.apache.hadoop.hbase.client.Table ht, byte[][] families, int rows, int flushes)
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testInvalidColumnFamily()
void	testMajorCompaction()
void	testMajorCompactionOnFamily()
void	testMinorCompaction()
void	testMinorCompactionOnFamily()

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

testMajorCompaction

public void testMajorCompaction()
                         throws IOException,
                                InterruptedException

Throws:

IOException

InterruptedException

testMinorCompaction

public void testMinorCompaction()
                         throws IOException,
                                InterruptedException

Throws:

IOException

InterruptedException

testMajorCompactionOnFamily

public void testMajorCompactionOnFamily()
                                 throws IOException,
                                        InterruptedException

Throws:

IOException

InterruptedException

testMinorCompactionOnFamily

public void testMinorCompactionOnFamily()
                                 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)
                 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

Throws:

IOException

InterruptedException

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