public class GoalViolationDetector
extends java.lang.Object
implements java.lang.Runnable
Constructor and Description |
---|
GoalViolationDetector(KafkaCruiseControlConfig config,
LoadMonitor loadMonitor,
java.util.Queue<Anomaly> anomalies,
org.apache.kafka.common.utils.Time time,
KafkaCruiseControl kafkaCruiseControl,
java.util.List<java.lang.String> selfHealingGoals) |
Modifier and Type | Method and Description |
---|---|
double |
balancednessScore() |
void |
run() |
public GoalViolationDetector(KafkaCruiseControlConfig config, LoadMonitor loadMonitor, java.util.Queue<Anomaly> anomalies, org.apache.kafka.common.utils.Time time, KafkaCruiseControl kafkaCruiseControl, java.util.List<java.lang.String> selfHealingGoals)
public double balancednessScore()
_detectionGoals
.public void run()
run
in interface java.lang.Runnable