Package 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

@Private
public class CacheAwareLoadBalancer
extends StochasticLoadBalancer

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	CacheAwareLoadBalancer.CacheAwareCandidateGenerator
(package private) static class	CacheAwareLoadBalancer.CacheAwareCostFunction
(package private) static class	CacheAwareLoadBalancer.CacheAwareRegionSkewnessCostFunction
private class	CacheAwareLoadBalancer.CacheAwareSkewnessCandidateGenerator
static enum	CacheAwareLoadBalancer.GeneratorFunctionType

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.conf.Configuration	configuration
private static final org.slf4j.Logger	LOG

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, loads, MAX_RUNNING_TIME_KEY, MAX_STEPS_KEY, MIN_COST_NEED_BALANCE_KEY, OVERALL_COST_FUNCTION_NAME, regionCacheRatioOnOldServerMap, 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, provider, rackManager, regionFinder, slop, useRegionFinder

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

BOGUS_SERVER_NAME, HBASE_RSGROUP_LOADBALANCER_CLASS

Constructor Summary

Constructors

Constructor	Description
CacheAwareLoadBalancer()

Method Summary

Modifier and Type	Method	Description
private void	addCostFunction(List<CostFunction> costFunctions, CostFunction costFunction)
protected Map<Class<? extends CandidateGenerator>,CandidateGenerator>	createCandidateGenerators()
protected List<CostFunction>	createCostFunctions(org.apache.hadoop.conf.Configuration configuration)
private RegionInfo	getRegionInfoByEncodedName(BalancerClusterState cluster, String regionName)
void	loadConf(org.apache.hadoop.conf.Configuration configuration)
void	updateClusterMetrics(ClusterMetrics clusterMetrics)	Set the current cluster status.
private void	updateRegionLoad()	Collect the amount of region cached for all the regions from all the active region servers.

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

balanceTable, composeAttributeName, computeCost, functionCost, getCandidateGenerators, getCostFunctionNames, getCostFunctions, getRandomGenerator, initCosts, needsBalance, nextAction, sendRejectionReasonToRingBuffer, setRackManager, updateBalancerLoadInfo, updateCostsAndWeightsWithAction, updateMetricsSize

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

balanceCluster, getConf, getDefaultSlop, idleRegionServerExist, initialize, isStopped, onConfigurationChange, postMasterStartupInitialize, preBalanceCluster, randomAssignment, regionOffline, regionOnline, retainAssignment, roundRobinAssignment, setClusterInfoProvider, sloppyRegionServerExist, stop, toEnsumbleTableLoad, updateBalancerStatus

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

configuration

private org.apache.hadoop.conf.Configuration configuration

Constructor Details

CacheAwareLoadBalancer

public CacheAwareLoadBalancer()

Method Details

loadConf

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

Overrides:

loadConf in class StochasticLoadBalancer

createCandidateGenerators

protected Map<Class<? extends CandidateGenerator>,CandidateGenerator> createCandidateGenerators()

Overrides:

createCandidateGenerators in class StochasticLoadBalancer

createCostFunctions

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

Overrides:

createCostFunctions in class StochasticLoadBalancer

addCostFunction

private void addCostFunction(List<CostFunction> costFunctions,
 CostFunction costFunction)

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

updateRegionLoad

private void updateRegionLoad()

Collect the amount of region cached for all the regions from all the active region servers.

getRegionInfoByEncodedName

private RegionInfo getRegionInfoByEncodedName(BalancerClusterState cluster,
 String regionName)