org.apache.hadoop.hbase.regionserver

Class TestRegionMergeTransactionOnCluster

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestRegionMergeTransactionOnCluster

public class TestRegionMergeTransactionOnCluster
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestRegionMergeTransactionOnCluster.MyMaster
(package private) static class	TestRegionMergeTransactionOnCluster.MyMasterRpcServices

Field Summary

Fields

Modifier and Type	Field and Description
private static org.apache.hadoop.hbase.client.Admin	ADMIN
static HBaseClassTestRule	CLASS_RULE
private static byte[]	FAMILYNAME
private static int	INITIAL_REGION_NUM
private static org.slf4j.Logger	LOG
private static org.apache.hadoop.hbase.master.HMaster	MASTER
org.junit.rules.TestName	name
private static int	NB_SERVERS
private static byte[]	QUALIFIER
private static byte[]	ROW
private static byte[][]	ROWS
private static int	ROWSIZE
(package private) static HBaseTestingUtility	TEST_UTIL
private static int	waitTime

Constructor Summary

Constructors

Constructor and Description
TestRegionMergeTransactionOnCluster()

Method Summary

Modifier and Type	Method and Description
static void	afterAllTests()
static void	beforeAllTests()
private org.apache.hadoop.hbase.client.Table	createTableAndLoadData(org.apache.hadoop.hbase.master.HMaster master, org.apache.hadoop.hbase.TableName tablename)
private org.apache.hadoop.hbase.client.Table	createTableAndLoadData(org.apache.hadoop.hbase.master.HMaster master, org.apache.hadoop.hbase.TableName tablename, int numRegions, int replication)
private void	loadData(org.apache.hadoop.hbase.client.Table table)
private static byte[][]	makeN(byte[] base, int n)
private org.apache.hadoop.hbase.util.PairOfSameType<org.apache.hadoop.hbase.client.RegionInfo>	mergeRegionsAndVerifyRegionNum(org.apache.hadoop.hbase.master.HMaster master, org.apache.hadoop.hbase.TableName tablename, int regionAnum, int regionBnum, int expectedRegionNum)
private org.apache.hadoop.hbase.util.PairOfSameType<org.apache.hadoop.hbase.client.RegionInfo>	requestMergeRegion(org.apache.hadoop.hbase.master.HMaster master, org.apache.hadoop.hbase.TableName tablename, int regionAnum, int regionBnum)
void	testCleanMergeReference()
void	testMerge() This test tests 1, merging region not online; 2, merging same two regions; 3, merging unknown regions.
void	testMergeAndRestartingMaster() Not really restarting the master.
void	testMergeWithReplicas()
void	testWholesomeMerge()
private void	verifyRowCount(org.apache.hadoop.hbase.client.Table table, int expectedRegionNum)
private void	waitAndVerifyRegionNum(org.apache.hadoop.hbase.master.HMaster master, org.apache.hadoop.hbase.TableName tablename, int expectedRegionNum)

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 org.junit.rules.TestName name

NB_SERVERS

private static final int NB_SERVERS

See Also:

Constant Field Values

FAMILYNAME

private static final byte[] FAMILYNAME

QUALIFIER

private static final byte[] QUALIFIER

ROW

private static byte[] ROW

INITIAL_REGION_NUM

private static final int INITIAL_REGION_NUM

See Also:

Constant Field Values

ROWSIZE

private static final int ROWSIZE

See Also:

Constant Field Values

ROWS

private static byte[][] ROWS

waitTime

private static int waitTime

TEST_UTIL

static final HBaseTestingUtility TEST_UTIL

MASTER

private static org.apache.hadoop.hbase.master.HMaster MASTER

ADMIN

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

Constructor Detail

TestRegionMergeTransactionOnCluster

public TestRegionMergeTransactionOnCluster()

Method Detail

beforeAllTests

public static void beforeAllTests()
                           throws Exception

Throws:

Exception

afterAllTests

public static void afterAllTests()
                          throws Exception

Throws:

Exception

testWholesomeMerge

public void testWholesomeMerge()
                        throws Exception

Throws:

Exception

testMergeAndRestartingMaster

public void testMergeAndRestartingMaster()
                                  throws Exception

Not really restarting the master. Simulate it by clear of new region state since it is not persisted, will be lost after master restarts.

Throws:

Exception

testCleanMergeReference

public void testCleanMergeReference()
                             throws Exception

Throws:

Exception

testMerge

public void testMerge()
               throws Exception

This test tests 1, merging region not online; 2, merging same two regions; 3, merging unknown regions. They are in one test case so that we don't have to create many tables, and these tests are simple.

Throws:

Exception

testMergeWithReplicas

public void testMergeWithReplicas()
                           throws Exception

Throws:

Exception

mergeRegionsAndVerifyRegionNum

private org.apache.hadoop.hbase.util.PairOfSameType<org.apache.hadoop.hbase.client.RegionInfo> mergeRegionsAndVerifyRegionNum(org.apache.hadoop.hbase.master.HMaster master,
                                                                                                                              org.apache.hadoop.hbase.TableName tablename,
                                                                                                                              int regionAnum,
                                                                                                                              int regionBnum,
                                                                                                                              int expectedRegionNum)
                                                                                                                       throws Exception

Throws:

Exception

requestMergeRegion

private org.apache.hadoop.hbase.util.PairOfSameType<org.apache.hadoop.hbase.client.RegionInfo> requestMergeRegion(org.apache.hadoop.hbase.master.HMaster master,
                                                                                                                  org.apache.hadoop.hbase.TableName tablename,
                                                                                                                  int regionAnum,
                                                                                                                  int regionBnum)
                                                                                                           throws Exception

Throws:

Exception

waitAndVerifyRegionNum

private void waitAndVerifyRegionNum(org.apache.hadoop.hbase.master.HMaster master,
                                    org.apache.hadoop.hbase.TableName tablename,
                                    int expectedRegionNum)
                             throws Exception

Throws:

Exception

createTableAndLoadData

private org.apache.hadoop.hbase.client.Table createTableAndLoadData(org.apache.hadoop.hbase.master.HMaster master,
                                                                    org.apache.hadoop.hbase.TableName tablename)
                                                             throws Exception

Throws:

Exception

createTableAndLoadData

private org.apache.hadoop.hbase.client.Table createTableAndLoadData(org.apache.hadoop.hbase.master.HMaster master,
                                                                    org.apache.hadoop.hbase.TableName tablename,
                                                                    int numRegions,
                                                                    int replication)
                                                             throws Exception

Throws:

Exception

makeN

private static byte[][] makeN(byte[] base,
                              int n)

loadData

private void loadData(org.apache.hadoop.hbase.client.Table table)
               throws IOException

Throws:

IOException

verifyRowCount

private void verifyRowCount(org.apache.hadoop.hbase.client.Table table,
                            int expectedRegionNum)
                     throws IOException

Throws:

IOException