public class LeaderReplicaDistributionGoal extends ReplicaDistributionAbstractGoal
ReplicaDistributionAbstractGoal.ChangeType
Goal.ClusterModelStatsComparator
avgReplicasOnAliveBroker, balanceLowerLimit, balanceUpperLimit, brokerIdsAboveBalanceUpperLimit, brokerIdsUnderBalanceLowerLimit, fixOfflineReplicasOnly
balancingConstraint, finished, minMonitoredPartitionPercentage, numWindows, optimizationResultBuilder
Constructor and Description |
---|
LeaderReplicaDistributionGoal()
Constructor for Leader Replica Distribution Goal.
|
LeaderReplicaDistributionGoal(BalancingConstraint balancingConstraint)
Package private for unit test.
|
Modifier and Type | Method and Description |
---|---|
ActionAcceptance |
actionAcceptance(BalancingAction action,
ClusterModel clusterModel)
Check whether the given action is acceptable by this goal.
|
Goal.ClusterModelStatsComparator |
clusterModelStatsComparator()
Get an instance of
Goal.ClusterModelStatsComparator for this goal. |
String |
name()
Get the name of this goal.
|
protected void |
rebalanceForBroker(Broker broker,
ClusterModel clusterModel,
Set<Goal> optimizedGoals,
OptimizationOptions optimizationOptions)
Rebalance the given broker without violating the constraints of the current goal and optimized goals.
|
brokersToBalance, clusterModelCompletenessRequirements, finish, initGoalState, isHardGoal, selfSatisfied, updateGoalState
changeObservership, configure, maybeApplyBalancingAction, maybeMoveReplicaBetweenDisks, optimize, shouldExclude, toString, updateReplicationFactor
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
canChangeReplicationFactor
public LeaderReplicaDistributionGoal()
public LeaderReplicaDistributionGoal(BalancingConstraint balancingConstraint)
public ActionAcceptance actionAcceptance(BalancingAction action, ClusterModel clusterModel)
action
- Action to be checked for acceptance.clusterModel
- The state of the cluster.ActionAcceptance.ACCEPT
if the action is acceptable by this goal,
ActionAcceptance.REPLICA_REJECT
otherwise.public Goal.ClusterModelStatsComparator clusterModelStatsComparator()
Goal
Goal.ClusterModelStatsComparator
for this goal.
The Goal.ClusterModelStatsComparator.compare(ClusterModelStats, ClusterModelStats)
method should give a
preference between two ClusterModelStats
.
Cruise Control will not reuse the returned instance.
The returned value must not be null.public String name()
Goal
name
in interface Goal
name
in class AbstractGoal
protected void rebalanceForBroker(Broker broker, ClusterModel clusterModel, Set<Goal> optimizedGoals, OptimizationOptions optimizationOptions)
rebalanceForBroker
in class AbstractGoal
broker
- Broker to be balanced.clusterModel
- The state of the cluster.optimizedGoals
- Optimized goals.optimizationOptions
- Options to take into account during optimization -- e.g. excluded topics.