Package org.apache.hadoop.hbase.regionserver

Class TestCompactionState

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestCompactionState

@Tag("org.apache.hadoop.hbase.testclassification.VerySlowRegionServerTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestCompactionState
extends Object

Unit tests to test retrieving table/region compaction state

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field	Description
private String	name
private static final HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestCompactionState()

Method Summary

Modifier and Type	Method	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)
void	setTestName(org.junit.jupiter.api.TestInfo testInfo)
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 Details

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

name

private String name

Constructor Details

TestCompactionState

public TestCompactionState()

Method Details

setTestName

@BeforeEach
public void setTestName(org.junit.jupiter.api.TestInfo testInfo)

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testMajorCompactionStateFromAdmin

@Test
public void testMajorCompactionStateFromAdmin()
                                       throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testMinorCompactionStateFromAdmin

@Test
public void testMinorCompactionStateFromAdmin()
                                       throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testMajorCompactionOnFamilyStateFromAdmin

@Test
public void testMajorCompactionOnFamilyStateFromAdmin()
                                               throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testMinorCompactionOnFamilyStateFromAdmin

@Test
public void testMinorCompactionOnFamilyStateFromAdmin()
                                               throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testMajorCompactionStateFromMaster

@Test
public void testMajorCompactionStateFromMaster()
                                        throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testMinorCompactionStateFromMaster

@Test
public void testMinorCompactionStateFromMaster()
                                        throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testMajorCompactionOnFamilyStateFromMaster

@Test
public void testMajorCompactionOnFamilyStateFromMaster()
                                                throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testMinorCompactionOnFamilyStateFromMaster

@Test
public void testMinorCompactionOnFamilyStateFromMaster()
                                                throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testInvalidColumnFamily

@Test
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:

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