Package org.apache.hadoop.hbase.master.balancer

Class TestFavoredStochasticLoadBalancer

java.lang.Object

org.apache.hadoop.hbase.master.balancer.BalancerTestBase

org.apache.hadoop.hbase.master.balancer.TestFavoredStochasticLoadBalancer

public class TestFavoredStochasticLoadBalancer
extends BalancerTestBase

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.master.balancer.BalancerTestBase

BalancerTestBase.MockMapping

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.hbase.client.Admin	admin
static final HBaseClassTestRule	CLASS_RULE
private SingleProcessHBaseCluster	cluster
private static final org.slf4j.Logger	LOG
private org.apache.hadoop.hbase.master.HMaster	master
private static final int	REGION_NUM
private static final int	SLAVES
private static final HBaseTestingUtil	TEST_UTIL

Fields inherited from class org.apache.hadoop.hbase.master.balancer.BalancerTestBase

clusterStateMocks, clusterStateMocksWithNoSlop, clusterStateMocksWithSlop, conf, largeCluster, regionId

Constructor Summary

Constructors

Constructor	Description
TestFavoredStochasticLoadBalancer()

Method Summary

Modifier and Type	Method	Description
private void	checkFavoredNodeAssignments(org.apache.hadoop.hbase.TableName tableName, org.apache.hadoop.hbase.favored.FavoredNodesManager fnm, org.apache.hadoop.hbase.master.assignment.RegionStates regionStates)
private void	compactTable(org.apache.hadoop.hbase.TableName tableName)
static void	setupBeforeClass()
void	startCluster()
void	stopCluster()
private void	stopServersAndWaitUntilProcessed(List<org.apache.hadoop.hbase.ServerName> currentFN)
void	test2FavoredNodesDead()
void	testAllFavoredNodesDead()
void	testAllFavoredNodesDeadMasterRestarted()
void	testBalancerWithoutFavoredNodes()
void	testBasicBalance()
void	testBasicRegionPlacementAndReplicaLoad()
void	testMisplacedRegions()
void	testRandomAssignmentWithNoFavNodes()
void	testRoundRobinAssignment()

Methods inherited from class org.apache.hadoop.hbase.master.balancer.BalancerTestBase

assertClusterAsBalanced, assertClusterOverallAsBalanced, assertRegionReplicaPlacement, convertToList, createRegions, createServerMap, mockCluster, mockClusterServers, mockClusterServers, mockClusterServers, mockClusterServersUnsorted, mockClusterServersWithTables, mockUniformClusterServers, printMock, printStats, randomRegions, randomRegions, randomServer, randomServers, reconcile, returnRegions, returnServer, returnServers, uniformRegions, updateLoad

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

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

SLAVES

private static final int SLAVES

See Also:

• Constant Field Values

REGION_NUM

private static final int REGION_NUM

See Also:

• Constant Field Values

admin

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

master

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

cluster

private SingleProcessHBaseCluster cluster

Constructor Details

TestFavoredStochasticLoadBalancer

public TestFavoredStochasticLoadBalancer()

Method Details

setupBeforeClass

public static void setupBeforeClass()
                             throws Exception

Throws:

Exception

startCluster

public void startCluster()
                  throws Exception

Throws:

Exception

stopCluster

public void stopCluster()
                 throws Exception

Throws:

Exception

testBasicBalance

public void testBasicBalance()
                      throws Exception

Throws:

Exception

testRoundRobinAssignment

public void testRoundRobinAssignment()
                              throws Exception

Throws:

Exception

testBasicRegionPlacementAndReplicaLoad

public void testBasicRegionPlacementAndReplicaLoad()
                                            throws Exception

Throws:

Exception

testRandomAssignmentWithNoFavNodes

public void testRandomAssignmentWithNoFavNodes()
                                        throws Exception

Throws:

Exception

testBalancerWithoutFavoredNodes

public void testBalancerWithoutFavoredNodes()
                                     throws Exception

Throws:

Exception

testMisplacedRegions

public void testMisplacedRegions()
                          throws Exception

Throws:

Exception

test2FavoredNodesDead

public void test2FavoredNodesDead()
                           throws Exception

Throws:

Exception

testAllFavoredNodesDead

public void testAllFavoredNodesDead()
                             throws Exception

Throws:

Exception

testAllFavoredNodesDeadMasterRestarted

public void testAllFavoredNodesDeadMasterRestarted()
                                            throws Exception

Throws:

Exception

checkFavoredNodeAssignments

private void checkFavoredNodeAssignments(org.apache.hadoop.hbase.TableName tableName,
 org.apache.hadoop.hbase.favored.FavoredNodesManager fnm,
 org.apache.hadoop.hbase.master.assignment.RegionStates regionStates)
                                  throws IOException

Throws:

IOException

stopServersAndWaitUntilProcessed

private void stopServersAndWaitUntilProcessed(List<org.apache.hadoop.hbase.ServerName> currentFN)
                                       throws Exception

Throws:

Exception

compactTable

private void compactTable(org.apache.hadoop.hbase.TableName tableName)
                   throws IOException

Throws:

IOException