public static class DistributionThresholdUtils.ReplicaThresholds extends Object
Modifier and Type | Field and Description |
---|---|
int |
numReplicasLowerLimit |
int |
numReplicasUpperLimit |
Constructor and Description |
---|
ReplicaThresholds(int numReplicasUpperLimit,
int numReplicasLowerLimit) |
Modifier and Type | Method and Description |
---|---|
static DistributionThresholdUtils.ReplicaThresholds |
compute(OptimizationOptions optimizationOptions,
BalancingConstraint balancingConstraint,
double avgReplicasOnBroker,
double balancePercentage)
Computes the maximum and minimum number of replicas a broker should have, over which distribution goals will
attempt to move replicas out of / into the broker in order to achieve balance.
|
boolean |
equals(Object o) |
int |
hashCode() |
String |
toString() |
public final int numReplicasUpperLimit
public final int numReplicasLowerLimit
public ReplicaThresholds(int numReplicasUpperLimit, int numReplicasLowerLimit)
public static DistributionThresholdUtils.ReplicaThresholds compute(OptimizationOptions optimizationOptions, BalancingConstraint balancingConstraint, double avgReplicasOnBroker, double balancePercentage)
optimizationOptions
- Options to adjust balance limit in case goal optimization is triggered by goal
violation detector.balancingConstraint
- The balancing constraintavgReplicasOnBroker
- The average number of replicas per broker in the broker set of interest
(e.g. alive brokers, eligible destination brokers etc)balancePercentage
- The requested balance threshold.