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 BalancerClusterStateModifier and TypeFieldDescriptionprotected BalancerClusterStateCostFunction.clusterprivate BalancerClusterStateRegionPlanConditional.clusterMethods 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.areSomeRegionReplicasColocatedOnHost(BalancerClusterState c) private booleanStochasticLoadBalancer.areSomeRegionReplicasColocatedOnRack(BalancerClusterState c) (package private) BalanceActionRegionPlanConditionalCandidateGenerator.batchMovesAndResetClusterState(BalancerClusterState cluster, List<MoveRegionAction> moves) private longStochasticLoadBalancer.calculateMaxSteps(BalancerClusterState cluster) (package private) doubleStochasticLoadBalancer.computeCost(BalancerClusterState cluster, double previousCost) This is the main cost function.private RegionPlanConditionalBalancerConditionals.createConditional(Class<? extends RegionPlanConditional> clazz, BalancerClusterState cluster) 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) BalanceActionRegionPlanConditionalCandidateGenerator.generate(BalancerClusterState cluster) (package private) BalanceActionRegionReplicaCandidateGenerator.generate(BalancerClusterState cluster) (package private) BalanceActionRegionReplicaRackCandidateGenerator.generate(BalancerClusterState cluster) (package private) BalanceActionTableIsolationCandidateGenerator.generate(BalancerClusterState cluster) (package private) BalanceActionDistributeReplicasCandidateGenerator.generateCandidate(BalancerClusterState cluster, boolean isWeighing) (package private) BalanceActionDistributeReplicasCandidateGenerator.generateCandidate(BalancerClusterState cluster, boolean isWeighing, boolean isForced) (package private) abstract BalanceActionRegionPlanConditionalCandidateGenerator.generateCandidate(BalancerClusterState cluster, boolean isWeighing) Generates a balancing action to appease the conditional.(package private) BalanceActionSlopFixingCandidateGenerator.generateCandidate(BalancerClusterState cluster, boolean isWeighing) (package private) BalanceActionTableIsolationCandidateGenerator.generateCandidate(BalancerClusterState cluster, boolean isWeighing) 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) protected CandidateGeneratorFavoredStochasticBalancer.getRandomGenerator(BalancerClusterState cluster) Returns any candidate generator in randomprotected CandidateGeneratorStochasticLoadBalancer.getRandomGenerator(BalancerClusterState cluster) Select the candidate generator to use based on the cost of cost functions.private RegionInfoCacheAwareLoadBalancer.getRegionInfoByEncodedName(BalancerClusterState cluster, String regionName) (package private) intBalancerConditionals.getViolationCountChange(BalancerClusterState cluster, BalanceAction action) Indicates whether the action is good for our conditional compliance.(package private) doubleRegionPlanConditionalCandidateGenerator.getWeight(BalancerClusterState cluster) private doubleLocalityBasedCandidateGenerator.getWeightedLocality(BalancerClusterState cluster, int region, int server) protected final booleanBaseLoadBalancer.idleRegionServerExist(BalancerClusterState c) (package private) voidStochasticLoadBalancer.initCosts(BalancerClusterState cluster) (package private) booleanBalancerConditionals.isServerHostingIsolatedTables(BalancerClusterState cluster, int serverIdx) (package private) booleanTableIsolationConditional.isServerHostingIsolatedTables(BalancerClusterState cluster, int serverIdx) (package private) booleanBalancerConditionals.isViolating(BalancerClusterState cluster, BalanceAction action) Check if the proposed action violates conditionals(package private) voidBalancerConditionals.loadClusterState(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) Pair<CandidateGenerator,BalanceAction> StochasticLoadBalancer.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) voidStoreFileTableSkewCostFunction.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 servers(package private) voidRegionPlanConditional.setClusterState(BalancerClusterState cluster) (package private) booleanBalancerConditionals.shouldRunBalancer(BalancerClusterState cluster) (package private) List<RegionPlan>AssignRegionAction.toRegionPlans(BalancerClusterState cluster) (package private) List<RegionPlan>BalanceAction.NullBalanceAction.toRegionPlans(BalancerClusterState cluster) (package private) abstract List<RegionPlan>BalanceAction.toRegionPlans(BalancerClusterState cluster) Returns the Action represented as RegionPlans(package private) List<RegionPlan>MoveBatchAction.toRegionPlans(BalancerClusterState cluster) (package private) List<RegionPlan>MoveRegionAction.toRegionPlans(BalancerClusterState cluster) (package private) List<RegionPlan>SwapRegionsAction.toRegionPlans(BalancerClusterState cluster) private Optional<BalanceAction>LocalityBasedCandidateGenerator.tryMoveOrSwap(BalancerClusterState cluster, int fromServer, int fromRegion, int toServer) (package private) voidRegionPlanConditionalCandidateGenerator.undoBatchAction(BalancerClusterState cluster, MoveBatchAction batchAction) (package private) voidStochasticLoadBalancer.updateCostsAndWeightsWithAction(BalancerClusterState cluster, BalanceAction action) Update both the costs of costfunctions and the weights of candidate generators(package private) booleanRegionPlanConditionalCandidateGenerator.willBeAccepted(BalancerClusterState cluster, BalanceAction action) Constructors in org.apache.hadoop.hbase.master.balancer with parameters of type BalancerClusterStateModifierConstructorDescriptionDistributeReplicasConditional(BalancerConditionals balancerConditionals, BalancerClusterState cluster) MetaTableIsolationConditional(BalancerConditionals balancerConditionals, BalancerClusterState cluster) (package private)RegionPlanConditional(org.apache.hadoop.conf.Configuration conf, BalancerClusterState cluster) (package private)SystemTableIsolationConditional(BalancerConditionals balancerConditionals, BalancerClusterState cluster) (package private)TableIsolationConditional(TableIsolationCandidateGenerator generator, BalancerConditionals balancerConditionals, BalancerClusterState cluster)