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 BalancerClusterState
CostFunction.cluster
private BalancerClusterState
RegionPlanConditional.cluster
Methods in org.apache.hadoop.hbase.master.balancer that return BalancerClusterStateModifier and TypeMethodDescriptionprivate BalancerClusterState
BaseLoadBalancer.createCluster
(List<ServerName> servers, Collection<RegionInfo> regions) Methods in org.apache.hadoop.hbase.master.balancer with parameters of type BalancerClusterStateModifier and TypeMethodDescriptionprivate boolean
StochasticLoadBalancer.areSomeRegionReplicasColocatedOnHost
(BalancerClusterState c) private boolean
StochasticLoadBalancer.areSomeRegionReplicasColocatedOnRack
(BalancerClusterState c) (package private) BalanceAction
RegionPlanConditionalCandidateGenerator.batchMovesAndResetClusterState
(BalancerClusterState cluster, List<MoveRegionAction> moves) private long
StochasticLoadBalancer.calculateMaxSteps
(BalancerClusterState cluster) (package private) double
StochasticLoadBalancer.computeCost
(BalancerClusterState cluster, double previousCost) This is the main cost function.private RegionPlanConditional
BalancerConditionals.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 BalanceAction
CacheAwareLoadBalancer.CacheAwareCandidateGenerator.generate
(BalancerClusterState cluster) (package private) abstract BalanceAction
CandidateGenerator.generate
(BalancerClusterState cluster) (package private) BalanceAction
FavoredStochasticBalancer.FavoredNodeLoadPicker.generate
(BalancerClusterState cluster) protected BalanceAction
FavoredStochasticBalancer.FavoredNodeLocalityPicker.generate
(BalancerClusterState cluster) (package private) BalanceAction
LoadCandidateGenerator.generate
(BalancerClusterState cluster) (package private) BalanceAction
LocalityBasedCandidateGenerator.generate
(BalancerClusterState cluster) (package private) BalanceAction
RandomCandidateGenerator.generate
(BalancerClusterState cluster) (package private) BalanceAction
RegionPlanConditionalCandidateGenerator.generate
(BalancerClusterState cluster) (package private) BalanceAction
RegionReplicaCandidateGenerator.generate
(BalancerClusterState cluster) (package private) BalanceAction
RegionReplicaRackCandidateGenerator.generate
(BalancerClusterState cluster) (package private) BalanceAction
TableIsolationCandidateGenerator.generate
(BalancerClusterState cluster) (package private) BalanceAction
DistributeReplicasCandidateGenerator.generateCandidate
(BalancerClusterState cluster, boolean isWeighing) (package private) BalanceAction
DistributeReplicasCandidateGenerator.generateCandidate
(BalancerClusterState cluster, boolean isWeighing, boolean isForced) (package private) abstract BalanceAction
RegionPlanConditionalCandidateGenerator.generateCandidate
(BalancerClusterState cluster, boolean isWeighing) Generates a balancing action to appease the conditional.(package private) BalanceAction
SlopFixingCandidateGenerator.generateCandidate
(BalancerClusterState cluster, boolean isWeighing) (package private) BalanceAction
TableIsolationCandidateGenerator.generateCandidate
(BalancerClusterState cluster, boolean isWeighing) private BalanceAction
CacheAwareLoadBalancer.CacheAwareCandidateGenerator.generatePlan
(BalancerClusterState cluster, int regionIndex, int currentServerIndex, float cacheRatioOnCurrentServer, int oldServerIndex, float cacheRatioOnOldServer) private int
FavoredStochasticBalancer.FavoredNodeLocalityPicker.getDifferentFavoredNode
(BalancerClusterState cluster, List<ServerName> favoredNodes, int currentServer) protected final long
RegionReplicaGroupingCostFunction.getMaxCost
(BalancerClusterState cluster) protected CandidateGenerator
FavoredStochasticBalancer.getRandomGenerator
(BalancerClusterState cluster) Returns any candidate generator in randomprotected CandidateGenerator
StochasticLoadBalancer.getRandomGenerator
(BalancerClusterState cluster) Select the candidate generator to use based on the cost of cost functions.private RegionInfo
CacheAwareLoadBalancer.getRegionInfoByEncodedName
(BalancerClusterState cluster, String regionName) (package private) int
BalancerConditionals.getViolationCountChange
(BalancerClusterState cluster, BalanceAction action) Indicates whether the action is good for our conditional compliance.(package private) double
RegionPlanConditionalCandidateGenerator.getWeight
(BalancerClusterState cluster) private double
LocalityBasedCandidateGenerator.getWeightedLocality
(BalancerClusterState cluster, int region, int server) protected final boolean
BaseLoadBalancer.idleRegionServerExist
(BalancerClusterState c) (package private) void
StochasticLoadBalancer.initCosts
(BalancerClusterState cluster) (package private) boolean
BalancerConditionals.isServerHostingIsolatedTables
(BalancerClusterState cluster, int serverIdx) (package private) boolean
TableIsolationConditional.isServerHostingIsolatedTables
(BalancerClusterState cluster, int serverIdx) (package private) boolean
BalancerConditionals.isViolating
(BalancerClusterState cluster, BalanceAction action) Check if the proposed action violates conditionals(package private) void
BalancerConditionals.loadClusterState
(BalancerClusterState cluster) private boolean
CacheAwareLoadBalancer.CacheAwareCandidateGenerator.moveRegionToOldServer
(BalancerClusterState cluster, int regionIndex, int currentServerIndex, float cacheRatioOnCurrentServer, int oldServerIndex, float cacheRatioOnOldServer) private boolean
SimpleLoadBalancer.needsBalance
(BalancerClusterState c) (package private) boolean
StochasticLoadBalancer.needsBalance
(TableName tableName, BalancerClusterState cluster) (package private) Pair<CandidateGenerator,
BalanceAction> StochasticLoadBalancer.nextAction
(BalancerClusterState cluster) private int
CacheAwareLoadBalancer.CacheAwareSkewnessCandidateGenerator.pickLeastCachedRegion
(BalancerClusterState cluster, int thisServer) private int
FavoredStochasticBalancer.FavoredNodeLoadPicker.pickLeastLoadedFNServer
(BalancerClusterState cluster, List<ServerName> favoredNodes, int currentServerIndex) private int
FavoredStochasticBalancer.FavoredNodeLoadPicker.pickLeastLoadedServer
(BalancerClusterState cluster, int thisServer) private int
LoadCandidateGenerator.pickLeastLoadedServer
(BalancerClusterState cluster, int thisServer) private int
FavoredStochasticBalancer.FavoredNodeLocalityPicker.pickLowestLocalRegionOnServer
(BalancerClusterState cluster, int server) private int
FavoredStochasticBalancer.FavoredNodeLoadPicker.pickMostLoadedServer
(BalancerClusterState cluster) private int
LoadCandidateGenerator.pickMostLoadedServer
(BalancerClusterState cluster, int thisServer) (package private) int
CandidateGenerator.pickOtherRandomRack
(BalancerClusterState cluster, int rackIndex) (package private) int
CandidateGenerator.pickOtherRandomServer
(BalancerClusterState cluster, int serverIndex) (package private) int
CandidateGenerator.pickRandomRack
(BalancerClusterState cluster) (package private) int
CandidateGenerator.pickRandomRegion
(BalancerClusterState cluster, int server, double chanceOfNoSwap) From a list of regions pick a random one.(package private) BalanceAction
CacheAwareLoadBalancer.CacheAwareSkewnessCandidateGenerator.pickRandomRegions
(BalancerClusterState cluster, int thisServer, int otherServer) (package private) BalanceAction
CandidateGenerator.pickRandomRegions
(BalancerClusterState cluster, int thisServer, int otherServer) (package private) int
CandidateGenerator.pickRandomServer
(BalancerClusterState cluster) (package private) void
CacheAwareLoadBalancer.CacheAwareCostFunction.prepare
(BalancerClusterState cluster) (package private) void
CacheAwareLoadBalancer.CacheAwareRegionSkewnessCostFunction.prepare
(BalancerClusterState cluster) (package private) void
CostFromRegionLoadFunction.prepare
(BalancerClusterState cluster) (package private) void
CostFunction.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) void
HeterogeneousRegionCountCostFunction.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) void
LocalityBasedCostFunction.prepare
(BalancerClusterState cluster) (package private) void
MoveCostFunction.prepare
(BalancerClusterState cluster) (package private) void
PrimaryRegionCountSkewCostFunction.prepare
(BalancerClusterState cluster) (package private) void
RegionCountSkewCostFunction.prepare
(BalancerClusterState cluster) (package private) final void
RegionReplicaGroupingCostFunction.prepare
(BalancerClusterState cluster) (package private) void
TableSkewCostFunction.prepare
(BalancerClusterState cluster) private ServerName
BaseLoadBalancer.randomAssignment
(BalancerClusterState cluster, RegionInfo regionInfo, List<ServerName> servers) Used to assign a single region to a random server.private void
BaseLoadBalancer.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) void
RegionPlanConditional.setClusterState
(BalancerClusterState cluster) (package private) boolean
BalancerConditionals.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) void
RegionPlanConditionalCandidateGenerator.undoBatchAction
(BalancerClusterState cluster, MoveBatchAction batchAction) (package private) void
StochasticLoadBalancer.updateCostsAndWeightsWithAction
(BalancerClusterState cluster, BalanceAction action) Update both the costs of costfunctions and the weights of candidate generators(package private) boolean
RegionPlanConditionalCandidateGenerator.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)