org.apache.hadoop.hbase.master.assignment

Class TestMergeTableRegionsProcedure

java.lang.Object

org.apache.hadoop.hbase.master.assignment.TestMergeTableRegionsProcedure

public class TestMergeTableRegionsProcedure
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
private static org.apache.hadoop.hbase.client.Admin	admin
private long	assignFailedCount
private org.apache.hadoop.hbase.procedure2.ProcedureMetrics	assignProcMetrics
private long	assignSubmittedCount
static HBaseClassTestRule	CLASS_RULE
private static byte[]	FAMILY
private static int	initialRegionCount
private static org.slf4j.Logger	LOG
private long	mergeFailedCount
private org.apache.hadoop.hbase.procedure2.ProcedureMetrics	mergeProcMetrics
private long	mergeSubmittedCount
org.junit.rules.TestName	name
private long	unassignFailedCount
private org.apache.hadoop.hbase.procedure2.ProcedureMetrics	unassignProcMetrics
private long	unassignSubmittedCount
private static HBaseTestingUtility	UTIL

Constructor Summary

Constructors

Constructor and Description
TestMergeTableRegionsProcedure()

Method Summary

Modifier and Type	Method and Description
List<org.apache.hadoop.hbase.client.RegionInfo>	assertRegionCount(org.apache.hadoop.hbase.TableName tableName, int nregions)
static void	cleanupTest()
private void	collectAssignmentManagerMetrics()
private List<org.apache.hadoop.hbase.client.RegionInfo>	createTable(org.apache.hadoop.hbase.TableName tableName)
private org.apache.hadoop.hbase.procedure2.ProcedureExecutor<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>	getMasterProcedureExecutor()
private int	loadARowPerRegion(org.apache.hadoop.hbase.client.Table t, List<org.apache.hadoop.hbase.client.RegionInfo> ris)
private void	resetProcExecutorTestingKillFlag()
void	setup()
static void	setupCluster()
private static void	setupConf(org.apache.hadoop.conf.Configuration conf)
void	tearDown()
private void	testMerge(org.apache.hadoop.hbase.TableName tableName, int mergeCount)
void	testMergeRegionsConcurrently() This tests two concurrent region merges
void	testMergeTenRegions() This tests ten region merges in one go.
void	testMergeTwoRegions() This tests two region merges
void	testMergeWithoutPONR()
void	testRecoveryAndDoubleExecution()
void	testRollbackAndDoubleExecution()

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

name

public final org.junit.rules.TestName name

UTIL

private static final HBaseTestingUtility UTIL

initialRegionCount

private static final int initialRegionCount

See Also:

Constant Field Values

FAMILY

private static final byte[] FAMILY

admin

private static org.apache.hadoop.hbase.client.Admin admin

mergeProcMetrics

private org.apache.hadoop.hbase.procedure2.ProcedureMetrics mergeProcMetrics

assignProcMetrics

private org.apache.hadoop.hbase.procedure2.ProcedureMetrics assignProcMetrics

unassignProcMetrics

private org.apache.hadoop.hbase.procedure2.ProcedureMetrics unassignProcMetrics

mergeSubmittedCount

private long mergeSubmittedCount

mergeFailedCount

private long mergeFailedCount

assignSubmittedCount

private long assignSubmittedCount

assignFailedCount

private long assignFailedCount

unassignSubmittedCount

private long unassignSubmittedCount

unassignFailedCount

private long unassignFailedCount

Constructor Detail

TestMergeTableRegionsProcedure

public TestMergeTableRegionsProcedure()

Method Detail

setupConf

private static void setupConf(org.apache.hadoop.conf.Configuration conf)

setupCluster

public static void setupCluster()
                         throws Exception

Throws:

Exception

cleanupTest

public static void cleanupTest()
                        throws Exception

Throws:

Exception

setup

public void setup()
           throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

resetProcExecutorTestingKillFlag

private void resetProcExecutorTestingKillFlag()

loadARowPerRegion

private int loadARowPerRegion(org.apache.hadoop.hbase.client.Table t,
                              List<org.apache.hadoop.hbase.client.RegionInfo> ris)
                       throws IOException

Throws:

IOException

testMergeTwoRegions

public void testMergeTwoRegions()
                         throws Exception

This tests two region merges

Throws:

Exception

testMerge

private void testMerge(org.apache.hadoop.hbase.TableName tableName,
                       int mergeCount)
                throws IOException

Throws:

IOException

testMergeTenRegions

public void testMergeTenRegions()
                         throws Exception

This tests ten region merges in one go.

Throws:

Exception

testMergeRegionsConcurrently

public void testMergeRegionsConcurrently()
                                  throws Exception

This tests two concurrent region merges

Throws:

Exception

testRecoveryAndDoubleExecution

public void testRecoveryAndDoubleExecution()
                                    throws Exception

Throws:

Exception

testRollbackAndDoubleExecution

public void testRollbackAndDoubleExecution()
                                    throws Exception

Throws:

Exception

testMergeWithoutPONR

public void testMergeWithoutPONR()
                          throws Exception

Throws:

Exception

createTable

private List<org.apache.hadoop.hbase.client.RegionInfo> createTable(org.apache.hadoop.hbase.TableName tableName)
                                                             throws Exception

Throws:

Exception

assertRegionCount

public List<org.apache.hadoop.hbase.client.RegionInfo> assertRegionCount(org.apache.hadoop.hbase.TableName tableName,
                                                                         int nregions)
                                                                  throws Exception

Throws:

Exception

getMasterProcedureExecutor

private org.apache.hadoop.hbase.procedure2.ProcedureExecutor<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv> getMasterProcedureExecutor()

collectAssignmentManagerMetrics

private void collectAssignmentManagerMetrics()