public class MaxReplicaMovementParallelismGoal extends AbstractAcceptanceGoal
balancingConstraint, finished, minMonitoredPartitionPercentage, numWindows, optimizationResultBuilder, proposalStatsBuilder
Constructor and Description |
---|
MaxReplicaMovementParallelismGoal() |
MaxReplicaMovementParallelismGoal(BalancingConstraint balancingConstraint)
Used by tests
|
Modifier and Type | Method and Description |
---|---|
void |
configure(Map<String,?> configs)
Configure this class with the given key-value pairs
|
String |
name()
Get the name of this goal.
|
ActionAcceptance |
partitionActionAcceptance(PartitionBalancingAction action,
ClusterModel clusterModel)
All replica in a PartitionBalancingAction should belong to same partition.
|
ActionAcceptance |
replicaActionAcceptance(ReplicaBalancingAction 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.
|
brokersToBalance, clusterModelCompletenessRequirements, finish, initGoalState, isHardGoal, partitionActionSelfSatisfied, rebalanceForBroker, replicaActionSelfSatisfied, updateGoalState
changeObservership, maybeApplyBalancingAction, maybeApplyBalancingAction, maybeMoveReplicaBetweenDisks, optimize, proposalTrackingOptions, relocateReplica, selfSatisfied, shouldExclude, shouldExclude, shouldTryLeadershipMovement, toString, tryAcceptProposal, updateReplicationFactor
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
actionAcceptance, canChangeReplicationFactor, clusterModelStatsComparator, optimize
public MaxReplicaMovementParallelismGoal()
public MaxReplicaMovementParallelismGoal(BalancingConstraint balancingConstraint)
public void configure(Map<String,?> configs)
CruiseControlConfigurable
configure
in interface CruiseControlConfigurable
configure
in class AbstractGoal
public ActionAcceptance replicaActionAcceptance(ReplicaBalancingAction action, ClusterModel clusterModel)
action
- Action to be checked for acceptance.clusterModel
- State of the cluster before application of the action.public ActionAcceptance partitionActionAcceptance(PartitionBalancingAction action, ClusterModel clusterModel)
action
- Action to be checked for acceptance.clusterModel
- State of the cluster before application of the action.