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

Class TestBaseLoadBalancer

java.lang.Object

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

org.apache.hadoop.hbase.master.balancer.TestBaseLoadBalancer

public class TestBaseLoadBalancer
extends BalancerTestBase

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestBaseLoadBalancer.MockBalancer

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 static TestBaseLoadBalancer.MockBalancer	loadBalancer
private static final org.slf4j.Logger	LOG
private static final org.apache.hadoop.hbase.ServerName	master
org.junit.rules.TestName	name
private static final int	NUM_SERVERS
private static org.apache.hadoop.hbase.master.RackManager	rackManager
(package private) int[][]	regionsAndServersMocks
private static org.apache.hadoop.hbase.ServerName[]	servers

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

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

Constructor Summary

Constructors

Constructor	Description
TestBaseLoadBalancer()

Method Summary

Modifier and Type	Method	Description
private void	assertRetainedAssignment(Map<org.apache.hadoop.hbase.client.RegionInfo,org.apache.hadoop.hbase.ServerName> existing, List<org.apache.hadoop.hbase.ServerName> servers, Map<org.apache.hadoop.hbase.ServerName,List<org.apache.hadoop.hbase.client.RegionInfo>> assignment)	Asserts a valid retained assignment plan.
private void	assignRegions(List<org.apache.hadoop.hbase.client.RegionInfo> regions, List<org.apache.hadoop.hbase.ServerName> servers, Map<org.apache.hadoop.hbase.ServerName,List<org.apache.hadoop.hbase.client.RegionInfo>> clusterState)
static void	beforeAllTests()
private List<org.apache.hadoop.hbase.ServerName>	getListOfServerNames(List<org.apache.hadoop.hbase.master.balancer.ServerAndLoad> sals)
void	testBulkAssignment()	Tests the bulk assignment used during cluster startup.
void	testClusterRegionLocations()
void	testClusterServersWithSameHostPort()
void	testRandomAssignment()
private void	testRandomAssignment(int numberOfIdleServers)
void	testRegionAvailability()
void	testRegionAvailabilityWithRegionMoves()
void	testRetainAssignment()	Test the cluster startup bulk assignment which attempts to retain assignment info.

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, 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 Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

loadBalancer

private static TestBaseLoadBalancer.MockBalancer loadBalancer

LOG

private static final org.slf4j.Logger LOG

master

private static final org.apache.hadoop.hbase.ServerName master

rackManager

private static org.apache.hadoop.hbase.master.RackManager rackManager

NUM_SERVERS

private static final int NUM_SERVERS

See Also:

• Constant Field Values

servers

private static org.apache.hadoop.hbase.ServerName[] servers

regionsAndServersMocks

int[][] regionsAndServersMocks

name

public org.junit.rules.TestName name

Constructor Details

TestBaseLoadBalancer

public TestBaseLoadBalancer()

Method Details

beforeAllTests

public static void beforeAllTests()
                           throws Exception

Throws:

Exception

testBulkAssignment

public void testBulkAssignment()
                        throws Exception

Tests the bulk assignment used during cluster startup. Round-robin. Should yield a balanced cluster so same invariant as the load balancer holds, all servers holding either floor(avg) or ceiling(avg).

Throws:

Exception

testRetainAssignment

public void testRetainAssignment()
                          throws Exception

Test the cluster startup bulk assignment which attempts to retain assignment info.

Throws:

Exception

testRandomAssignment

public void testRandomAssignment()
                          throws Exception

Throws:

Exception

testRandomAssignment

private void testRandomAssignment(int numberOfIdleServers)
                           throws Exception

Throws:

Exception

testRegionAvailability

public void testRegionAvailability()
                            throws Exception

Throws:

Exception

testRegionAvailabilityWithRegionMoves

public void testRegionAvailabilityWithRegionMoves()
                                           throws Exception

Throws:

Exception

getListOfServerNames

private List<org.apache.hadoop.hbase.ServerName> getListOfServerNames(List<org.apache.hadoop.hbase.master.balancer.ServerAndLoad> sals)

assertRetainedAssignment

private void assertRetainedAssignment(Map<org.apache.hadoop.hbase.client.RegionInfo,org.apache.hadoop.hbase.ServerName> existing,
 List<org.apache.hadoop.hbase.ServerName> servers,
 Map<org.apache.hadoop.hbase.ServerName,List<org.apache.hadoop.hbase.client.RegionInfo>> assignment)

Asserts a valid retained assignment plan.

Must meet the following conditions:

• Every input region has an assignment, and to an online server
• If a region had an existing assignment to a server with the same address a a currently online server, it will be assigned to it

testClusterServersWithSameHostPort

public void testClusterServersWithSameHostPort()

assignRegions

private void assignRegions(List<org.apache.hadoop.hbase.client.RegionInfo> regions,
 List<org.apache.hadoop.hbase.ServerName> servers,
 Map<org.apache.hadoop.hbase.ServerName,List<org.apache.hadoop.hbase.client.RegionInfo>> clusterState)

testClusterRegionLocations

public void testClusterRegionLocations()