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

Class TestStochasticLoadBalancer

java.lang.Object

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

org.apache.hadoop.hbase.master.balancer.StochasticBalancerTestBase

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

public class TestStochasticLoadBalancer
extends StochasticBalancerTestBase

Nested Class Summary

Nested Classes

Modifier and Type	Class	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	Description
static final 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 final String	REGION_KEY
private static org.apache.hadoop.conf.Configuration	storedConfiguration

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

dummyMetricsStochasticBalancer, loadBalancer

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

clusterStateMocks, clusterStateMocksWithNoSlop, clusterStateMocksWithSlop, conf, largeCluster, regionId

Constructor Summary

Constructors

Constructor	Description
TestStochasticLoadBalancer()

Method Summary

Modifier and Type	Method	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 org.apache.hadoop.hbase.ServerMetrics	mockServerMetricsWithCpRequests(List<org.apache.hadoop.hbase.client.RegionInfo> regionsOnServer, long cpRequestCount)
private boolean	needsBalanceIdleRegion(int[] cluster)
static void	saveInitialConfiguration()
void	testAdditionalCostFunction()
void	testBalanceOfSloppyServers()
void	testCostAfterUndoAction()
void	testCPRequestCost()
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.StochasticBalancerTestBase

beforeAllTests, increaseMaxRunTimeOrFail, setMaxRunTime, testWithClusterWithIteration, testWithClusterWithIteration

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

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 Details

TestStochasticLoadBalancer

public TestStochasticLoadBalancer()

Method Details

saveInitialConfiguration

public static void saveInitialConfiguration()

beforeEachTest

public void beforeEachTest()

mockServerMetricsWithCpRequests

private org.apache.hadoop.hbase.ServerMetrics mockServerMetricsWithCpRequests(List<org.apache.hadoop.hbase.client.RegionInfo> regionsOnServer,
 long cpRequestCount)

testCPRequestCost

public void testCPRequestCost()

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)