org.apache.hadoop.hbase.master.balancer

Class LocalityBasedCandidateGenerator

java.lang.Object

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

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

@InterfaceAudience.Private
class LocalityBasedCandidateGenerator
extends 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)

Methods inherited from class org.apache.hadoop.hbase.master.balancer.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 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)

getWeightedLocality

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

setServices

void setServices(MasterServices services)