org.apache.hadoop.hbase.master

Class TestAssignmentManager.MockedLoadBalancer

java.lang.Object

org.apache.hadoop.hbase.master.balancer.BaseLoadBalancer

org.apache.hadoop.hbase.master.balancer.StochasticLoadBalancer

org.apache.hadoop.hbase.master.TestAssignmentManager.MockedLoadBalancer

All Implemented Interfaces:

ConfigurationObserver, LoadBalancer, Stoppable

Enclosing class:

TestAssignmentManager

public static class TestAssignmentManager.MockedLoadBalancer
extends StochasticLoadBalancer

Mocked load balancer class used in the testcase to make sure that the testcase waits until random assignment is called and the gate variable is set to true.

Nested Class Summary

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

BaseLoadBalancer.Cluster

Field Summary

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

KEEP_REGION_LOADS, MAX_RUNNING_TIME_KEY, MAX_STEPS_KEY, STEPS_PER_REGION_KEY

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

clusterStatus, config, masterServerName, metricsBalancer, rackManager, regionFinder, services, slop, TABLES_ON_MASTER, tablesOnMaster

Fields inherited from interface org.apache.hadoop.hbase.master.LoadBalancer

BOGUS_SERVER_NAME

Constructor Summary

Constructors

Constructor and Description
MockedLoadBalancer()

Method Summary

Modifier and Type	Method and Description
ServerName	randomAssignment(HRegionInfo regionInfo, java.util.List<ServerName> servers) Used to assign a single region to a random server.
java.util.Map<ServerName,java.util.List<HRegionInfo>>	retainAssignment(java.util.Map<HRegionInfo,ServerName> regions, java.util.List<ServerName> servers) Generates a bulk assignment startup plan, attempting to reuse the existing assignment information from META, but adjusting for the specified list of available/online servers available for assignment.
void	setGateVariable(java.util.concurrent.atomic.AtomicBoolean gate)

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

areSomeRegionReplicasColocated, balanceCluster, balanceCluster, composeAttributeName, computeCost, getCostFunctionNames, initCosts, onConfigurationChange, setClusterStatus, setConf, setMasterServices, setSlop, updateCostsWithAction, updateMetricsSize

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

assignMasterRegions, balanceMasterRegions, createCluster, getConf, getRegionAssignmentsByServer, getTablesOnMaster, immediateAssignment, initialize, isStopped, needsBalance, regionOffline, regionOnline, roundRobinAssignment, setRackManager, shouldBeOnMaster, stop, tablesOnMaster

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MockedLoadBalancer

public MockedLoadBalancer()

Method Detail

setGateVariable

public void setGateVariable(java.util.concurrent.atomic.AtomicBoolean gate)

randomAssignment

public ServerName randomAssignment(HRegionInfo regionInfo,
                                   java.util.List<ServerName> servers)

Description copied from class: BaseLoadBalancer

Used to assign a single region to a random server.

Specified by:

randomAssignment in interface LoadBalancer

Overrides:

randomAssignment in class BaseLoadBalancer

Parameters:

regionInfo - Region for which this selection is being done.

Returns:

Servername

retainAssignment

public java.util.Map<ServerName,java.util.List<HRegionInfo>> retainAssignment(java.util.Map<HRegionInfo,ServerName> regions,
                                                                              java.util.List<ServerName> servers)

Description copied from class: BaseLoadBalancer

Generates a bulk assignment startup plan, attempting to reuse the existing assignment information from META, but adjusting for the specified list of available/online servers available for assignment.

Takes a map of all regions to their existing assignment from META. Also takes a list of online servers for regions to be assigned to. Attempts to retain all assignment, so in some instances initial assignment will not be completely balanced.

Any leftover regions without an existing server to be assigned to will be assigned randomly to available servers.

Specified by:

retainAssignment in interface LoadBalancer

Overrides:

retainAssignment in class BaseLoadBalancer

Parameters:

regions - regions and existing assignment from meta

servers - available servers

Returns:

map of servers and regions to be assigned to them