Package org.apache.hadoop.hbase.client

Class TestAsyncRegionAdminApi

java.lang.Object

org.apache.hadoop.hbase.client.AbstractTestUpdateConfiguration

org.apache.hadoop.hbase.client.TestAsyncAdminBase

org.apache.hadoop.hbase.client.TestAsyncRegionAdminApi

@Tag("org.apache.hadoop.hbase.testclassification.LargeTests") @Tag("org.apache.hadoop.hbase.testclassification.ClientTests")
public class TestAsyncRegionAdminApi
extends TestAsyncAdminBase

Class to test asynchronous region admin operations.

See Also:

• This test and it used to be joined it was taking longer than our ten minute timeout so they were split.

Field Summary

Fields inherited from class org.apache.hadoop.hbase.client.TestAsyncAdminBase

admin, ASYNC_CONN, FAMILY, FAMILY_0, FAMILY_1, getAdmin, LOG, tableName, TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestAsyncRegionAdminApi(Supplier<org.apache.hadoop.hbase.client.AsyncAdmin> admin)

Method Summary

Modifier and Type	Method	Description
private void	compactionTest(org.apache.hadoop.hbase.TableName tableName, int flushes, org.apache.hadoop.hbase.client.CompactionState expectedState, boolean singleFamily)
private static int	countStoreFilesInFamilies(List<org.apache.hadoop.hbase.regionserver.Region> regions, byte[][] families)
private static int	countStoreFilesInFamily(List<org.apache.hadoop.hbase.regionserver.Region> regions, byte[] family)
(package private) org.apache.hadoop.hbase.client.RegionInfo	createTableAndGetOneRegion(org.apache.hadoop.hbase.TableName tableName)
(package private) static void	loadData(org.apache.hadoop.hbase.TableName tableName, byte[][] families, int rows)
(package private) static void	loadData(org.apache.hadoop.hbase.TableName tableName, byte[][] families, int rows, int flushes)
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testAssignRegionAndUnassignRegion()
void	testCompact()
void	testCompactionSwitchStates()
void	testCompactMob()
void	testCompactRegionServer()
void	testFlushTableAndRegion()
void	testGetOnlineRegions()
void	testGetRegionByStateOfTable()
void	testMoveRegion()
void	testNonExistentTableCompaction()
private void	testNonExistentTableCompaction(org.apache.hadoop.hbase.client.CompactionState compactionState)
private void	waitUntilMobCompactionFinished(org.apache.hadoop.hbase.TableName tableName)

Methods inherited from class org.apache.hadoop.hbase.client.TestAsyncAdminBase

createTableWithDefaultConf, createTableWithDefaultConf, createTableWithDefaultConf, createTableWithDefaultConf, createTableWithDefaultConf, createTableWithDefaultConf, parameters, setUp, tearDown

Methods inherited from class org.apache.hadoop.hbase.client.AbstractTestUpdateConfiguration

addResourceToRegionServerConfiguration, replaceHBaseSiteXML, restoreHBaseSiteXML, setUpConfigurationFiles

Methods inherited from class java.lang.Object

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

Constructor Details

TestAsyncRegionAdminApi

public TestAsyncRegionAdminApi(Supplier<org.apache.hadoop.hbase.client.AsyncAdmin> admin)

Method Details

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testAssignRegionAndUnassignRegion

@TestTemplate
public void testAssignRegionAndUnassignRegion()
                                       throws Exception

Throws:

Exception

createTableAndGetOneRegion

org.apache.hadoop.hbase.client.RegionInfo createTableAndGetOneRegion(org.apache.hadoop.hbase.TableName tableName)
                                                              throws IOException,
InterruptedException,
ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

testGetRegionByStateOfTable

@TestTemplate
public void testGetRegionByStateOfTable()
                                 throws Exception

Throws:

Exception

testMoveRegion

@TestTemplate
public void testMoveRegion()
                    throws Exception

Throws:

Exception

testGetOnlineRegions

@TestTemplate
public void testGetOnlineRegions()
                          throws Exception

Throws:

Exception

testFlushTableAndRegion

@TestTemplate
public void testFlushTableAndRegion()
                             throws Exception

Throws:

Exception

waitUntilMobCompactionFinished

private void waitUntilMobCompactionFinished(org.apache.hadoop.hbase.TableName tableName)
                                     throws ExecutionException,
InterruptedException

Throws:

ExecutionException

InterruptedException

testCompactMob

@TestTemplate
public void testCompactMob()
                    throws Exception

Throws:

Exception

testCompactRegionServer

@TestTemplate
public void testCompactRegionServer()
                             throws Exception

Throws:

Exception

testCompactionSwitchStates

@TestTemplate
public void testCompactionSwitchStates()
                                throws Exception

Throws:

Exception

testCompact

@TestTemplate
public void testCompact()
                 throws Exception

Throws:

Exception

compactionTest

private void compactionTest(org.apache.hadoop.hbase.TableName tableName,
 int flushes,
 org.apache.hadoop.hbase.client.CompactionState expectedState,
 boolean singleFamily)
                     throws Exception

Throws:

Exception

testNonExistentTableCompaction

@TestTemplate
public void testNonExistentTableCompaction()

testNonExistentTableCompaction

private void testNonExistentTableCompaction(org.apache.hadoop.hbase.client.CompactionState compactionState)

countStoreFilesInFamily

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

countStoreFilesInFamilies

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

loadData

static void loadData(org.apache.hadoop.hbase.TableName tableName,
 byte[][] families,
 int rows)
              throws IOException

Throws:

IOException

loadData

static void loadData(org.apache.hadoop.hbase.TableName tableName,
 byte[][] families,
 int rows,
 int flushes)
              throws IOException

Throws:

IOException