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