public class AnomalyDetectorState extends Object
Constructor and Description |
---|
AnomalyDetectorState(org.apache.kafka.common.utils.Time time,
Map<AnomalyType,Boolean> selfHealingEnabled,
int numCachedRecentAnomalyStates,
DataBalancerMetricsRegistry metricRegistry) |
Modifier and Type | Method and Description |
---|---|
void |
markSelfHealingFinished(String anomalyId)
Update anomaly status once associated self-healing operation has finished.
|
void |
setSelfHealingFor(AnomalyType anomalyType,
boolean isSelfHealingEnabled) |
String |
toString() |
public AnomalyDetectorState(org.apache.kafka.common.utils.Time time, Map<AnomalyType,Boolean> selfHealingEnabled, int numCachedRecentAnomalyStates, DataBalancerMetricsRegistry metricRegistry)
public void markSelfHealingFinished(String anomalyId)
anomalyId
- Unique id of anomaly which triggered self-healing operation.public void setSelfHealingFor(AnomalyType anomalyType, boolean isSelfHealingEnabled)