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

Class StochasticBalancerTestBase

java.lang.Object

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

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

Direct Known Subclasses:

StochasticBalancerTestBase2, TestBalancerDecision, TestBalancerRejection, TestCacheAwareLoadBalancerCostFunctions, TestStochasticLoadBalancer, TestStochasticLoadBalancerBalanceCluster, TestStochasticLoadBalancerHeterogeneousCost, TestStochasticLoadBalancerHeterogeneousCostRules, TestStochasticLoadBalancerHeterogeneousCostRulesLoadFromHDFS, TestStochasticLoadBalancerLargeCluster, TestStochasticLoadBalancerMidCluster, TestStochasticLoadBalancerRegionReplica, TestStochasticLoadBalancerRegionReplicaLargeCluster, TestStochasticLoadBalancerRegionReplicaSameHosts, TestStochasticLoadBalancerRegionReplicaWithRacks, TestStochasticLoadBalancerSmallCluster

public class StochasticBalancerTestBase
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
protected static DummyMetricsStochasticBalancer	dummyMetricsStochasticBalancer
protected static org.apache.hadoop.hbase.master.balancer.StochasticLoadBalancer	loadBalancer
private static final org.slf4j.Logger	LOG
private static final Duration	MAX_MAX_RUN_TIME

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

clusterStateMocks, clusterStateMocksWithNoSlop, clusterStateMocksWithSlop, conf, largeCluster, regionId

Constructor Summary

Constructors

Constructor	Description
StochasticBalancerTestBase()

Method Summary

Modifier and Type	Method	Description
static void	beforeAllTests()
private Duration	getCurrentMaxRunTime()
protected void	increaseMaxRunTimeOrFail()
protected void	setMaxRunTime(Duration maxRunTime)
protected void	testWithClusterWithIteration(int numNodes, int numRegions, int numRegionsPerServer, int replication, int numTables, boolean assertFullyBalanced, boolean assertFullyBalancedForReplicas)
protected void	testWithClusterWithIteration(Map<org.apache.hadoop.hbase.ServerName,List<org.apache.hadoop.hbase.client.RegionInfo>> serverMap, org.apache.hadoop.hbase.master.RackManager rackManager, boolean assertFullyBalanced, boolean assertFullyBalancedForReplicas)

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

LOG

private static final org.slf4j.Logger LOG

MAX_MAX_RUN_TIME

private static final Duration MAX_MAX_RUN_TIME

loadBalancer

protected static org.apache.hadoop.hbase.master.balancer.StochasticLoadBalancer loadBalancer

dummyMetricsStochasticBalancer

protected static DummyMetricsStochasticBalancer dummyMetricsStochasticBalancer

Constructor Details

StochasticBalancerTestBase

public StochasticBalancerTestBase()

Method Details

beforeAllTests

public static void beforeAllTests()
                           throws Exception

Throws:

Exception

setMaxRunTime

protected void setMaxRunTime(Duration maxRunTime)

testWithClusterWithIteration

protected void testWithClusterWithIteration(int numNodes,
 int numRegions,
 int numRegionsPerServer,
 int replication,
 int numTables,
 boolean assertFullyBalanced,
 boolean assertFullyBalancedForReplicas)

increaseMaxRunTimeOrFail

protected void increaseMaxRunTimeOrFail()

testWithClusterWithIteration

protected void testWithClusterWithIteration(Map<org.apache.hadoop.hbase.ServerName,List<org.apache.hadoop.hbase.client.RegionInfo>> serverMap,
 org.apache.hadoop.hbase.master.RackManager rackManager,
 boolean assertFullyBalanced,
 boolean assertFullyBalancedForReplicas)

getCurrentMaxRunTime

private Duration getCurrentMaxRunTime()