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

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

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE

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

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

Constructor Summary

Constructors

Constructor and Description
TestAsyncRegionAdminApi()

Method Summary

Modifier and Type	Method and 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)
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, params, setUp, setUpBeforeClass, tearDown, tearDownAfterClass

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

Constructor Detail

TestAsyncRegionAdminApi

public TestAsyncRegionAdminApi()

Method Detail

testAssignRegionAndUnassignRegion

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

public void testGetRegionByStateOfTable()
                                 throws Exception

Throws:

Exception

testMoveRegion

public void testMoveRegion()
                    throws Exception

Throws:

Exception

testGetOnlineRegions

public void testGetOnlineRegions()
                          throws Exception

Throws:

Exception

testFlushTableAndRegion

public void testFlushTableAndRegion()
                             throws Exception

Throws:

Exception

waitUntilMobCompactionFinished

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

Throws:

ExecutionException

InterruptedException

testCompactMob

public void testCompactMob()
                    throws Exception

Throws:

Exception

testCompactRegionServer

public void testCompactRegionServer()
                             throws Exception

Throws:

Exception

testCompactionSwitchStates

public void testCompactionSwitchStates()
                                throws Exception

Throws:

Exception

testCompact

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

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