public class MaxReplicaMovementParallelismGoal extends AbstractAcceptanceGoal
Goal.ClusterModelStatsComparator
balancingConstraint, finished, minMonitoredPartitionPercentage, numWindows, optimizationResultBuilder
Constructor and Description |
---|
MaxReplicaMovementParallelismGoal() |
MaxReplicaMovementParallelismGoal(BalancingConstraint balancingConstraint)
Used by tests
|
Modifier and Type | Method and Description |
---|---|
ActionAcceptance |
actionAcceptance(BalancingAction action,
ClusterModel clusterModel)
Brokers can have up to NUM_CONCURRENT_PARTITION_MOVEMENTS_PER_BROKER incoming/outgoing at one time;
if a partition has multiple replicas moving at once, each new destination replica counts as a movement,
to avoid overwhelming the source.
|
void |
configure(Map<String,?> configs)
Configure this class with the given key-value pairs
|
String |
name()
Get the name of this goal.
|
brokersToBalance, clusterModelCompletenessRequirements, finish, initGoalState, isHardGoal, rebalanceForBroker, selfSatisfied, updateGoalState
changeObservership, maybeApplyBalancingAction, maybeMoveReplicaBetweenDisks, optimize, shouldExclude, toString, updateReplicationFactor
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
canChangeReplicationFactor, clusterModelStatsComparator
public MaxReplicaMovementParallelismGoal()
public MaxReplicaMovementParallelismGoal(BalancingConstraint balancingConstraint)
public void configure(Map<String,?> configs)
CruiseControlConfigurable
configure
in interface CruiseControlConfigurable
configure
in class AbstractGoal
public ActionAcceptance actionAcceptance(BalancingAction action, ClusterModel clusterModel)
action
- Action to be checked for acceptance.clusterModel
- State of the cluster before application of the action.