org.apache.hadoop.hbase.master.balancer

Class CacheAwareLoadBalancer

java.lang.Object

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

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

org.apache.hadoop.hbase.master.balancer.CacheAwareLoadBalancer

All Implemented Interfaces:

ConfigurationObserver, LoadBalancer, Stoppable

@InterfaceAudience.Private
public class CacheAwareLoadBalancer
extends StochasticLoadBalancer

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CacheAwareLoadBalancer.GeneratorFunctionType

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

StochasticLoadBalancer.GeneratorType

Field Summary

Fields

Modifier and Type	Field and Description
static String	CACHE_RATIO_THRESHOLD
static float	CACHE_RATIO_THRESHOLD_DEFAULT
Float	ratioThreshold

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

candidateGenerators, COST_FUNCTIONS_COST_FUNCTIONS_KEY, costFunctions, DEFAULT_KEEP_REGION_LOADS, DEFAULT_MAX_RUNNING_TIME, DEFAULT_MAX_STEPS, DEFAULT_MIN_COST_NEED_BALANCE, DEFAULT_RUN_MAX_STEPS, DEFAULT_STEPS_PER_REGION, KEEP_REGION_LOADS, MAX_RUNNING_TIME_KEY, MAX_STEPS_KEY, MIN_COST_NEED_BALANCE_KEY, OVERALL_COST_FUNCTION_NAME, RUN_MAX_STEPS_KEY, shuffledGeneratorClasses, STEPS_PER_REGION_KEY

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

BALANCER_DECISION_BUFFER_ENABLED, BALANCER_REJECTION_BUFFER_ENABLED, clusterStatus, DEFAULT_BALANCER_DECISION_BUFFER_ENABLED, DEFAULT_BALANCER_REJECTION_BUFFER_ENABLED, DEFAULT_HBASE_MASTER_LOADBALANCE_BYTABLE, isByTable, masterServerName, metricsBalancer, MIN_SERVER_BALANCE, onlySystemTablesOnMaster, rackManager, regionFinder, services, slop, useRegionFinder

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

BOGUS_SERVER_NAME, HBASE_RSGROUP_LOADBALANCER_CLASS, MOVE_THROTTLING, MOVE_THROTTLING_DEFAULT, SYSTEM_TABLES_ON_MASTER, TABLES_ON_MASTER

Constructor Summary

Constructors

Constructor and Description
CacheAwareLoadBalancer()

Method Summary

Modifier and Type	Method and Description
protected List<RegionPlan>	balanceTable(TableName tableName, Map<ServerName,List<RegionInfo>> loadOfOneTable) Given the cluster state this will try and approach an optimal balance.
protected Map<Class<? extends org.apache.hadoop.hbase.master.balancer.CandidateGenerator>,org.apache.hadoop.hbase.master.balancer.CandidateGenerator>	createCandidateGenerators()
protected List<org.apache.hadoop.hbase.master.balancer.CostFunction>	createCostFunctions(org.apache.hadoop.conf.Configuration configuration)
void	loadConf(org.apache.hadoop.conf.Configuration configuration)
void	throttle(RegionPlan plan)
void	updateClusterMetrics(ClusterMetrics clusterMetrics) Set the current cluster status.

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

functionCost, getRandomGenerator, updateBalancerLoadInfo

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

assignMasterSystemRegions, balanceCluster, balanceMasterRegions, getConf, getDefaultSlop, idleRegionServerExist, initialize, isStopped, onConfigurationChange, postMasterStartupInitialize, preBalanceCluster, randomAssignment, regionOffline, regionOnline, retainAssignment, roundRobinAssignment, setMasterServices, shouldBeOnMaster, sloppyRegionServerExist, stop, toEnsumbleTableLoad, updateBalancerStatus

Methods inherited from class java.lang.Object

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

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

isMasterCanHostUserRegions, isSystemTablesOnlyOnMaster, isTablesOnMaster

Field Detail

CACHE_RATIO_THRESHOLD

public static final String CACHE_RATIO_THRESHOLD

See Also:

Constant Field Values

CACHE_RATIO_THRESHOLD_DEFAULT

public static final float CACHE_RATIO_THRESHOLD_DEFAULT

See Also:

Constant Field Values

ratioThreshold

public Float ratioThreshold

Constructor Detail

CacheAwareLoadBalancer

public CacheAwareLoadBalancer()

Method Detail

loadConf

public void loadConf(org.apache.hadoop.conf.Configuration configuration)

Overrides:

loadConf in class StochasticLoadBalancer

createCandidateGenerators

protected Map<Class<? extends org.apache.hadoop.hbase.master.balancer.CandidateGenerator>,org.apache.hadoop.hbase.master.balancer.CandidateGenerator> createCandidateGenerators()

Overrides:

createCandidateGenerators in class StochasticLoadBalancer

createCostFunctions

protected List<org.apache.hadoop.hbase.master.balancer.CostFunction> createCostFunctions(org.apache.hadoop.conf.Configuration configuration)

Overrides:

createCostFunctions in class StochasticLoadBalancer

updateClusterMetrics

public void updateClusterMetrics(ClusterMetrics clusterMetrics)

Description copied from interface: LoadBalancer

Set the current cluster status. This allows a LoadBalancer to map host name to a server

Specified by:

updateClusterMetrics in interface LoadBalancer

Overrides:

updateClusterMetrics in class StochasticLoadBalancer

throttle

public void throttle(RegionPlan plan)

balanceTable

protected List<RegionPlan> balanceTable(TableName tableName,
                                        Map<ServerName,List<RegionInfo>> loadOfOneTable)

Description copied from class: StochasticLoadBalancer

Given the cluster state this will try and approach an optimal balance. This should always approach the optimal state given enough steps.

Overrides:

balanceTable in class StochasticLoadBalancer

Parameters:

tableName - the table to be balanced

loadOfOneTable - region load of servers for the specific one table

Returns:

List of plans