org.apache.hadoop.hbase.master.balancer

Class TestStochasticLoadBalancer

java.lang.Object

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

org.apache.hadoop.hbase.master.balancer.TestStochasticLoadBalancer

public class TestStochasticLoadBalancer
extends BalancerTestBase

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	TestStochasticLoadBalancer.MockCluster

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

BalancerTestBase.MockMapping

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private int[][][]	clusterRegionLocationMocks Data set for testLocalityCost: [test][0][0] = mapping of server to number of regions it hosts [test][region + 1][0] = server that region is hosted on [test][region + 1][server + 1] = locality for region on server
private float[]	expectedLocalities
private static String	REGION_KEY
private static org.apache.hadoop.conf.Configuration	storedConfiguration

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

clusterStateMocks, clusterStateMocksWithNoSlop, clusterStateMocksWithSlop, conf, dummyMetricsStochasticBalancer, largeCluster, loadBalancer, regionId

Constructor Summary

Constructors

Constructor and Description
TestStochasticLoadBalancer()

Method Summary

Modifier and Type	Method and Description
void	beforeEachTest()
private boolean	hasEmptyBalancerPlans(int[] mockCluster)
private boolean	hasEmptyBalancerPlans(int[][] mockCluster)
private boolean	hasEmptyBalancerPlans(Map<org.apache.hadoop.hbase.ServerName,List<org.apache.hadoop.hbase.client.RegionInfo>> servers)
private boolean	needsBalanceIdleRegion(int[] cluster)
static void	saveInitialConfiguration()
void	testAdditionalCostFunction()
void	testBalanceOfSloppyServers()
void	testCostAfterUndoAction()
void	testDefaultCostFunctionList()
void	testKeepRegionLoad()
void	testLocalityCost()
void	testLosingRs()
void	testMoveCost()
void	testMoveCostMultiplier()
void	testNeedBalance()
void	testRegionLoadCost()
void	testRegionLoadCostWhenDecrease()
void	testSkewCost()
void	testSloppyTablesLoadBalanceByTable()
void	testTableSkewCost()
void	testUpdateBalancerLoadInfo()
void	testUpdateStochasticCosts()
void	testUpdateStochasticCostsIfBalanceNotRan()

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

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

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

REGION_KEY

private static final String REGION_KEY

See Also:

Constant Field Values

expectedLocalities

private float[] expectedLocalities

storedConfiguration

private static org.apache.hadoop.conf.Configuration storedConfiguration

clusterRegionLocationMocks

private int[][][] clusterRegionLocationMocks

Data set for testLocalityCost: [test][0][0] = mapping of server to number of regions it hosts [test][region + 1][0] = server that region is hosted on [test][region + 1][server + 1] = locality for region on server

Constructor Detail

TestStochasticLoadBalancer

public TestStochasticLoadBalancer()

Method Detail

saveInitialConfiguration

public static void saveInitialConfiguration()

beforeEachTest

public void beforeEachTest()

testKeepRegionLoad

public void testKeepRegionLoad()
                        throws Exception

Throws:

Exception

testUpdateBalancerLoadInfo

public void testUpdateBalancerLoadInfo()

testUpdateStochasticCosts

public void testUpdateStochasticCosts()

testUpdateStochasticCostsIfBalanceNotRan

public void testUpdateStochasticCostsIfBalanceNotRan()

testNeedBalance

public void testNeedBalance()

testBalanceOfSloppyServers

public void testBalanceOfSloppyServers()

testSloppyTablesLoadBalanceByTable

public void testSloppyTablesLoadBalanceByTable()

hasEmptyBalancerPlans

private boolean hasEmptyBalancerPlans(int[] mockCluster)

hasEmptyBalancerPlans

private boolean hasEmptyBalancerPlans(int[][] mockCluster)

hasEmptyBalancerPlans

private boolean hasEmptyBalancerPlans(Map<org.apache.hadoop.hbase.ServerName,List<org.apache.hadoop.hbase.client.RegionInfo>> servers)

testLocalityCost

public void testLocalityCost()
                      throws Exception

Throws:

Exception

testMoveCostMultiplier

public void testMoveCostMultiplier()
                            throws Exception

Throws:

Exception

testMoveCost

public void testMoveCost()
                  throws Exception

Throws:

Exception

testSkewCost

public void testSkewCost()

testCostAfterUndoAction

public void testCostAfterUndoAction()

testTableSkewCost

public void testTableSkewCost()

testRegionLoadCost

public void testRegionLoadCost()

testRegionLoadCostWhenDecrease

public void testRegionLoadCostWhenDecrease()

testLosingRs

public void testLosingRs()
                  throws Exception

Throws:

Exception

testAdditionalCostFunction

public void testAdditionalCostFunction()

testDefaultCostFunctionList

public void testDefaultCostFunctionList()

needsBalanceIdleRegion

private boolean needsBalanceIdleRegion(int[] cluster)