org.apache.hadoop.hbase.master.balancer

Class StochasticLoadBalancer.LocalityBasedCostFunction

java.lang.Object

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

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

Direct Known Subclasses:

StochasticLoadBalancer.RackLocalityCostFunction, StochasticLoadBalancer.ServerLocalityCostFunction

Enclosing class:

StochasticLoadBalancer

abstract static class StochasticLoadBalancer.LocalityBasedCostFunction
extends StochasticLoadBalancer.CostFunction

Compute a cost of a potential cluster configuration based upon where HStoreFiles are located.

Field Summary

Fields

Modifier and Type	Field and Description
private double	bestLocality
private double	locality
private MasterServices	services
private BaseLoadBalancer.Cluster.LocalityType	type

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

cluster

Constructor Summary

Constructors

Constructor and Description
LocalityBasedCostFunction(org.apache.hadoop.conf.Configuration conf, MasterServices srv, BaseLoadBalancer.Cluster.LocalityType type, String localityCostKey, float defaultLocalityCost)

Method Summary

Modifier and Type	Method and Description
protected double	cost()
private int	getMostLocalEntityForRegion(int region)
private double	getWeightedLocality(int region, int entity)
(package private) void	init(BaseLoadBalancer.Cluster cluster) Called once per LB invocation to give the cost function to initialize it's state, and perform any costly calculation.
(package private) abstract int	regionIndexToEntityIndex(int region) Maps region to the current entity (server or rack) on which it is stored
protected void	regionMoved(int region, int oldServer, int newServer)
void	setServices(MasterServices srvc)

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

costFromArray, getMultiplier, isNeeded, postAction, scale, setMultiplier

Methods inherited from class java.lang.Object

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

Field Detail

type

private final BaseLoadBalancer.Cluster.LocalityType type

bestLocality

private double bestLocality

locality

private double locality

services

private MasterServices services

Constructor Detail

LocalityBasedCostFunction

LocalityBasedCostFunction(org.apache.hadoop.conf.Configuration conf,
                          MasterServices srv,
                          BaseLoadBalancer.Cluster.LocalityType type,
                          String localityCostKey,
                          float defaultLocalityCost)

Method Detail

regionIndexToEntityIndex

abstract int regionIndexToEntityIndex(int region)

Maps region to the current entity (server or rack) on which it is stored

setServices

public void setServices(MasterServices srvc)

init

void init(BaseLoadBalancer.Cluster cluster)

Description copied from class: StochasticLoadBalancer.CostFunction

Called once per LB invocation to give the cost function to initialize it's state, and perform any costly calculation.

Overrides:

init in class StochasticLoadBalancer.CostFunction

regionMoved

protected void regionMoved(int region,
                           int oldServer,
                           int newServer)

Overrides:

regionMoved in class StochasticLoadBalancer.CostFunction

cost

protected double cost()

Specified by:

cost in class StochasticLoadBalancer.CostFunction

getMostLocalEntityForRegion

private int getMostLocalEntityForRegion(int region)

getWeightedLocality

private double getWeightedLocality(int region,
                                   int entity)