public class MaxReplicaMovementParallelismGoal extends AbstractAcceptanceGoal
Goal.ClusterModelStatsComparator
balancingConstraint, finished, minMonitoredPartitionPercentage, numWindows, optimizationResultBuilder, proposalStats
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, maybeMoveReplicaBetweenDisks, optimize, relocateReplica, selfSatisfied, shouldExclude, shouldExclude, 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.