Package org.apache.hadoop.hbase.master.assignment

Class TestSplitTableRegionProcedure

java.lang.Object

org.apache.hadoop.hbase.master.assignment.TestSplitTableRegionProcedure

public class TestSplitTableRegionProcedure
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestSplitTableRegionProcedure.RegionServerHostingReplicaSlowOpenCopro	This copro is used to slow down opening of the replica regions.

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.hbase.master.assignment.AssignmentManager	am
private long	assignFailedCount
private org.apache.hadoop.hbase.procedure2.ProcedureMetrics	assignProcMetrics
private long	assignSubmittedCount
static final HBaseClassTestRule	CLASS_RULE
private static String	columnFamilyName1
private static String	columnFamilyName2
private static final org.slf4j.Logger	LOG
org.junit.rules.TestName	name
private static final int	rowCount
private long	splitFailedCount
private org.apache.hadoop.hbase.procedure2.ProcedureMetrics	splitProcMetrics
private long	splitSubmittedCount
private static final int	startRowNum
private long	unassignFailedCount
private org.apache.hadoop.hbase.procedure2.ProcedureMetrics	unassignProcMetrics
private long	unassignSubmittedCount
protected static final HBaseTestingUtility	UTIL

Constructor Summary

Constructors

Constructor	Description
TestSplitTableRegionProcedure()

Method Summary

Modifier and Type	Method	Description
static void	cleanupTest()
private void	collectAssignmentManagerMetrics()
private void	deleteData(org.apache.hadoop.hbase.TableName tableName, int startDeleteRowNum)
private org.apache.hadoop.hbase.procedure2.ProcedureExecutor<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>	getMasterProcedureExecutor()
void	setup()
static void	setupCluster()
private static void	setupConf(org.apache.hadoop.conf.Configuration conf)
void	tearDown()
void	testInvalidSplitKey()
void	testRecoveryAndDoubleExecution()
void	testRollbackAndDoubleExecution()
void	testRollbackForSplitTableRegionWithReplica()
void	testSplitRegionWhileTakingSnapshot()
void	testSplitTableRegion()
void	testSplitTableRegionDeletedRowsDaughter()
void	testSplitTableRegionEmptyDaughter()
void	testSplitTableRegionNoStoreFile()
void	testSplitTableRegionUnevenDaughter()
void	testSplitWithoutPONR()
private void	verify(org.apache.hadoop.hbase.TableName tableName, int splitRowNum)
private void	verifyData(org.apache.hadoop.hbase.regionserver.HRegion newReg, int startRow, int numRows, byte[]... families)

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

UTIL

protected static final HBaseTestingUtility UTIL

columnFamilyName1

private static String columnFamilyName1

columnFamilyName2

private static String columnFamilyName2

startRowNum

private static final int startRowNum

See Also:

• Constant Field Values

rowCount

private static final int rowCount

See Also:

• Constant Field Values

am

private org.apache.hadoop.hbase.master.assignment.AssignmentManager am

splitProcMetrics

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

assignProcMetrics

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

unassignProcMetrics

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

splitSubmittedCount

private long splitSubmittedCount

splitFailedCount

private long splitFailedCount

assignSubmittedCount

private long assignSubmittedCount

assignFailedCount

private long assignFailedCount

unassignSubmittedCount

private long unassignSubmittedCount

unassignFailedCount

private long unassignFailedCount

name

public org.junit.rules.TestName name

Constructor Details

TestSplitTableRegionProcedure

public TestSplitTableRegionProcedure()

Method Details

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

testRollbackForSplitTableRegionWithReplica

public void testRollbackForSplitTableRegionWithReplica()
                                                throws Exception

Throws:

Exception

testSplitTableRegion

public void testSplitTableRegion()
                          throws Exception

Throws:

Exception

testSplitTableRegionNoStoreFile

public void testSplitTableRegionNoStoreFile()
                                     throws Exception

Throws:

Exception

testSplitTableRegionUnevenDaughter

public void testSplitTableRegionUnevenDaughter()
                                        throws Exception

Throws:

Exception

testSplitTableRegionEmptyDaughter

public void testSplitTableRegionEmptyDaughter()
                                       throws Exception

Throws:

Exception

testSplitTableRegionDeletedRowsDaughter

public void testSplitTableRegionDeletedRowsDaughter()
                                             throws Exception

Throws:

Exception

testInvalidSplitKey

public void testInvalidSplitKey()
                         throws Exception

Throws:

Exception

testRollbackAndDoubleExecution

public void testRollbackAndDoubleExecution()
                                    throws Exception

Throws:

Exception

testRecoveryAndDoubleExecution

public void testRecoveryAndDoubleExecution()
                                    throws Exception

Throws:

Exception

testSplitWithoutPONR

public void testSplitWithoutPONR()
                          throws Exception

Throws:

Exception

testSplitRegionWhileTakingSnapshot

public void testSplitRegionWhileTakingSnapshot()
                                        throws Exception

Throws:

Exception

deleteData

private void deleteData(org.apache.hadoop.hbase.TableName tableName,
 int startDeleteRowNum)
                 throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

verify

private void verify(org.apache.hadoop.hbase.TableName tableName,
 int splitRowNum)
             throws IOException

Throws:

IOException

verifyData

private void verifyData(org.apache.hadoop.hbase.regionserver.HRegion newReg,
 int startRow,
 int numRows,
 byte[]... families)
                 throws IOException

Throws:

IOException

getMasterProcedureExecutor

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

collectAssignmentManagerMetrics

private void collectAssignmentManagerMetrics()