Uses of Class
org.apache.hadoop.hbase.master.balancer.BalancerClusterState
Packages that use BalancerClusterState
-
Uses of BalancerClusterState in org.apache.hadoop.hbase.master.balancer
Fields in org.apache.hadoop.hbase.master.balancer declared as BalancerClusterStateMethods in org.apache.hadoop.hbase.master.balancer that return BalancerClusterStateModifier and TypeMethodDescriptionprivate BalancerClusterStateBaseLoadBalancer.createCluster(List<ServerName> servers, Collection<RegionInfo> regions) Methods in org.apache.hadoop.hbase.master.balancer with parameters of type BalancerClusterStateModifier and TypeMethodDescriptionprivate booleanStochasticLoadBalancer.areSomeRegionReplicasColocated(BalancerClusterState c) private longStochasticLoadBalancer.calculateMaxSteps(BalancerClusterState cluster) (package private) doubleStochasticLoadBalancer.computeCost(BalancerClusterState cluster, double previousCost) This is the main cost function.private List<RegionPlan>StochasticLoadBalancer.createRegionPlans(BalancerClusterState cluster) Create all of the RegionPlan's needed to move from the initial cluster state to the desired state.protected BalanceActionCacheAwareLoadBalancer.CacheAwareCandidateGenerator.generate(BalancerClusterState cluster) (package private) abstract BalanceActionCandidateGenerator.generate(BalancerClusterState cluster) (package private) BalanceActionFavoredStochasticBalancer.FavoredNodeLoadPicker.generate(BalancerClusterState cluster) protected BalanceActionFavoredStochasticBalancer.FavoredNodeLocalityPicker.generate(BalancerClusterState cluster) (package private) BalanceActionLoadCandidateGenerator.generate(BalancerClusterState cluster) (package private) BalanceActionLocalityBasedCandidateGenerator.generate(BalancerClusterState cluster) (package private) BalanceActionRandomCandidateGenerator.generate(BalancerClusterState cluster) (package private) BalanceActionRegionReplicaCandidateGenerator.generate(BalancerClusterState cluster) (package private) BalanceActionRegionReplicaRackCandidateGenerator.generate(BalancerClusterState cluster) private BalanceActionCacheAwareLoadBalancer.CacheAwareCandidateGenerator.generatePlan(BalancerClusterState cluster, int regionIndex, int currentServerIndex, float cacheRatioOnCurrentServer, int oldServerIndex, float cacheRatioOnOldServer) private intFavoredStochasticBalancer.FavoredNodeLocalityPicker.getDifferentFavoredNode(BalancerClusterState cluster, List<ServerName> favoredNodes, int currentServer) protected final longRegionReplicaGroupingCostFunction.getMaxCost(BalancerClusterState cluster) private RegionInfoCacheAwareLoadBalancer.getRegionInfoByEncodedName(BalancerClusterState cluster, String regionName) private doubleLocalityBasedCandidateGenerator.getWeightedLocality(BalancerClusterState cluster, int region, int server) protected final booleanBaseLoadBalancer.idleRegionServerExist(BalancerClusterState c) (package private) voidStochasticLoadBalancer.initCosts(BalancerClusterState cluster) private booleanCacheAwareLoadBalancer.CacheAwareCandidateGenerator.moveRegionToOldServer(BalancerClusterState cluster, int regionIndex, int currentServerIndex, float cacheRatioOnCurrentServer, int oldServerIndex, float cacheRatioOnOldServer) private booleanSimpleLoadBalancer.needsBalance(BalancerClusterState c) (package private) booleanStochasticLoadBalancer.needsBalance(TableName tableName, BalancerClusterState cluster) (package private) BalanceActionStochasticLoadBalancer.nextAction(BalancerClusterState cluster) private intCacheAwareLoadBalancer.CacheAwareSkewnessCandidateGenerator.pickLeastCachedRegion(BalancerClusterState cluster, int thisServer) private intFavoredStochasticBalancer.FavoredNodeLoadPicker.pickLeastLoadedFNServer(BalancerClusterState cluster, List<ServerName> favoredNodes, int currentServerIndex) private intFavoredStochasticBalancer.FavoredNodeLoadPicker.pickLeastLoadedServer(BalancerClusterState cluster, int thisServer) private intLoadCandidateGenerator.pickLeastLoadedServer(BalancerClusterState cluster, int thisServer) private intFavoredStochasticBalancer.FavoredNodeLocalityPicker.pickLowestLocalRegionOnServer(BalancerClusterState cluster, int server) private intFavoredStochasticBalancer.FavoredNodeLoadPicker.pickMostLoadedServer(BalancerClusterState cluster) private intLoadCandidateGenerator.pickMostLoadedServer(BalancerClusterState cluster, int thisServer) (package private) intCandidateGenerator.pickOtherRandomRack(BalancerClusterState cluster, int rackIndex) (package private) intCandidateGenerator.pickOtherRandomServer(BalancerClusterState cluster, int serverIndex) (package private) intCandidateGenerator.pickRandomRack(BalancerClusterState cluster) (package private) intCandidateGenerator.pickRandomRegion(BalancerClusterState cluster, int server, double chanceOfNoSwap) From a list of regions pick a random one.(package private) BalanceActionCacheAwareLoadBalancer.CacheAwareSkewnessCandidateGenerator.pickRandomRegions(BalancerClusterState cluster, int thisServer, int otherServer) (package private) BalanceActionCandidateGenerator.pickRandomRegions(BalancerClusterState cluster, int thisServer, int otherServer) (package private) intCandidateGenerator.pickRandomServer(BalancerClusterState cluster) (package private) voidCacheAwareLoadBalancer.CacheAwareCostFunction.prepare(BalancerClusterState cluster) (package private) voidCacheAwareLoadBalancer.CacheAwareRegionSkewnessCostFunction.prepare(BalancerClusterState cluster) (package private) voidCostFromRegionLoadFunction.prepare(BalancerClusterState cluster) (package private) voidCostFunction.prepare(BalancerClusterState cluster) Called once per LB invocation to give the cost function to initialize it's state, and perform any costly calculation.(package private) voidHeterogeneousRegionCountCostFunction.prepare(BalancerClusterState cluster) Called once per LB invocation to give the cost function to initialize it's state, and perform any costly calculation.(package private) voidLocalityBasedCostFunction.prepare(BalancerClusterState cluster) (package private) voidMoveCostFunction.prepare(BalancerClusterState cluster) (package private) voidPrimaryRegionCountSkewCostFunction.prepare(BalancerClusterState cluster) (package private) voidRegionCountSkewCostFunction.prepare(BalancerClusterState cluster) (package private) final voidRegionReplicaGroupingCostFunction.prepare(BalancerClusterState cluster) (package private) voidTableSkewCostFunction.prepare(BalancerClusterState cluster) private ServerNameBaseLoadBalancer.randomAssignment(BalancerClusterState cluster, RegionInfo regionInfo, List<ServerName> servers) Used to assign a single region to a random server.private voidBaseLoadBalancer.roundRobinAssignment(BalancerClusterState cluster, List<RegionInfo> regions, List<ServerName> servers, Map<ServerName, List<RegionInfo>> assignments) Round-robin a list of regions to a list of serversprivate Optional<BalanceAction>LocalityBasedCandidateGenerator.tryMoveOrSwap(BalancerClusterState cluster, int fromServer, int fromRegion, int toServer) (package private) voidStochasticLoadBalancer.updateCostsAndWeightsWithAction(BalancerClusterState cluster, BalanceAction action)