org.apache.hadoop.hbase.master.balancer

Class StochasticLoadBalancer.LocalityBasedCandidateGenerator

java.lang.Object

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

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

Enclosing class:

StochasticLoadBalancer

static class StochasticLoadBalancer.LocalityBasedCandidateGenerator
extends StochasticLoadBalancer.CandidateGenerator

Field Summary

Fields

Modifier and Type	Field and Description
private MasterServices	masterServices

Constructor Summary

Constructors

Constructor and Description
LocalityBasedCandidateGenerator(MasterServices masterServices)

Method Summary

Modifier and Type	Method and Description
(package private) BaseLoadBalancer.Cluster.Action	generate(BaseLoadBalancer.Cluster cluster)
private double	getWeightedLocality(BaseLoadBalancer.Cluster cluster, int region, int server)
(package private) void	setServices(MasterServices services)
private org.apache.hbase.thirdparty.com.google.common.base.Optional<BaseLoadBalancer.Cluster.Action>	tryMoveOrSwap(BaseLoadBalancer.Cluster cluster, int fromServer, int fromRegion, int toServer) Try to generate a move/swap fromRegion between fromServer and toServer such that locality is improved.

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

getAction, getRandomIterationOrder, pickOtherRandomRack, pickOtherRandomServer, pickRandomRack, pickRandomRegion, pickRandomRegions, pickRandomServer

Methods inherited from class java.lang.Object

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

Field Detail

masterServices

private MasterServices masterServices

Constructor Detail

LocalityBasedCandidateGenerator

LocalityBasedCandidateGenerator(MasterServices masterServices)

Method Detail

generate

BaseLoadBalancer.Cluster.Action generate(BaseLoadBalancer.Cluster cluster)

Specified by:

generate in class StochasticLoadBalancer.CandidateGenerator

tryMoveOrSwap

private org.apache.hbase.thirdparty.com.google.common.base.Optional<BaseLoadBalancer.Cluster.Action> tryMoveOrSwap(BaseLoadBalancer.Cluster cluster,
                                                                                                                   int fromServer,
                                                                                                                   int fromRegion,
                                                                                                                   int toServer)

Try to generate a move/swap fromRegion between fromServer and toServer such that locality is improved. Returns empty optional if no move can be found

getWeightedLocality

private double getWeightedLocality(BaseLoadBalancer.Cluster cluster,
                                   int region,
                                   int server)

setServices

void setServices(MasterServices services)