org.apache.hadoop.hbase.master.balancer

Class TestStochasticLoadBalancerHeterogeneousCost

java.lang.Object

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

org.apache.hadoop.hbase.master.balancer.TestStochasticLoadBalancerHeterogeneousCost

public class TestStochasticLoadBalancerHeterogeneousCost
extends BalancerTestBase

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	TestStochasticLoadBalancerHeterogeneousCost.FairRandomCandidateGenerator
(package private) static class	TestStochasticLoadBalancerHeterogeneousCost.StochasticLoadTestBalancer

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

BalancerTestBase.MockMapping

Field Summary

Fields

Modifier and Type	Field and Description
private static double	ALLOWED_WINDOW
static HBaseClassTestRule	CLASS_RULE
private static HBaseTestingUtility	HTU
private static org.slf4j.Logger	LOG
private static String	RULES_FILE
private Queue<org.apache.hadoop.hbase.ServerName>	serverQueue

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
TestStochasticLoadBalancerHeterogeneousCost()

Method Summary

Modifier and Type	Method and Description
static void	beforeAllTests()
private org.apache.hadoop.hbase.master.balancer.ServerAndLoad	createServer(String host)
protected Map<org.apache.hadoop.hbase.ServerName,List<org.apache.hadoop.hbase.client.RegionInfo>>	createServerMap(int numNodes, int numRegions, int numRegionsPerServer, int replication, int numTables)
protected TreeMap<org.apache.hadoop.hbase.ServerName,List<org.apache.hadoop.hbase.client.RegionInfo>>	mockClusterServers(int[] mockCluster, int numTables)
void	testDefault()
void	testFourGroups()
private void	testHeterogeneousWithCluster(int numNodes, int numRegions, int numRegionsPerServer, List<String> rules)
void	testOneGroup()
void	testOverloaded()
void	testTwoGroups()
protected void	testWithCluster(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, mockCluster, mockClusterServers, mockClusterServers, mockClusterServersWithTables, mockUniformClusterServers, printMock, printStats, randomRegions, randomRegions, randomServer, randomServers, reconcile, returnRegions, returnServer, returnServers, 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

LOG

private static final org.slf4j.Logger LOG

ALLOWED_WINDOW

private static final double ALLOWED_WINDOW

See Also:

Constant Field Values

HTU

private static final HBaseTestingUtility HTU

RULES_FILE

private static String RULES_FILE

serverQueue

private Queue<org.apache.hadoop.hbase.ServerName> serverQueue

Constructor Detail

TestStochasticLoadBalancerHeterogeneousCost

public TestStochasticLoadBalancerHeterogeneousCost()

Method Detail

beforeAllTests

public static void beforeAllTests()
                           throws IOException

Throws:

IOException

testDefault

public void testDefault()
                 throws IOException

Throws:

IOException

testOneGroup

public void testOneGroup()
                  throws IOException

Throws:

IOException

testTwoGroups

public void testTwoGroups()
                   throws IOException

Throws:

IOException

testFourGroups

public void testFourGroups()
                    throws IOException

Throws:

IOException

testOverloaded

public void testOverloaded()
                    throws IOException

Throws:

IOException

testHeterogeneousWithCluster

private void testHeterogeneousWithCluster(int numNodes,
                                          int numRegions,
                                          int numRegionsPerServer,
                                          List<String> rules)
                                   throws IOException

Throws:

IOException

testWithCluster

protected void testWithCluster(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)

Overrides:

testWithCluster in class BalancerTestBase

createServerMap

protected Map<org.apache.hadoop.hbase.ServerName,List<org.apache.hadoop.hbase.client.RegionInfo>> createServerMap(int numNodes,
                                                                                                                  int numRegions,
                                                                                                                  int numRegionsPerServer,
                                                                                                                  int replication,
                                                                                                                  int numTables)

Overrides:

createServerMap in class BalancerTestBase

mockClusterServers

protected TreeMap<org.apache.hadoop.hbase.ServerName,List<org.apache.hadoop.hbase.client.RegionInfo>> mockClusterServers(int[] mockCluster,
                                                                                                                         int numTables)

Overrides:

mockClusterServers in class BalancerTestBase

createServer

private org.apache.hadoop.hbase.master.balancer.ServerAndLoad createServer(String host)