public class DiskFailures
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected OptimizationResult |
_optimizationResult |
Constructor and Description |
---|
DiskFailures(KafkaCruiseControl kafkaCruiseControl,
java.util.Map<java.lang.Integer,java.util.Map<java.lang.String,java.lang.Long>> failedDisksByBroker,
boolean allowCapacityEstimation,
boolean excludeRecentlyDemotedBrokers,
boolean excludeRecentlyRemovedBrokers,
java.util.List<java.lang.String> selfHealingGoals) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
anomalyId() |
java.util.Map<java.lang.Integer,java.util.Map<java.lang.String,java.lang.Long>> |
failedDisks()
Get the failed disks and their failure time in millisecond grouped by broker.
|
boolean |
fix()
Fix the anomaly with the system.
|
java.lang.String |
toString() |
protected OptimizationResult _optimizationResult
public DiskFailures(KafkaCruiseControl kafkaCruiseControl, java.util.Map<java.lang.Integer,java.util.Map<java.lang.String,java.lang.Long>> failedDisksByBroker, boolean allowCapacityEstimation, boolean excludeRecentlyDemotedBrokers, boolean excludeRecentlyRemovedBrokers, java.util.List<java.lang.String> selfHealingGoals)
public java.util.Map<java.lang.Integer,java.util.Map<java.lang.String,java.lang.Long>> failedDisks()
public java.lang.String anomalyId()
public boolean fix() throws KafkaCruiseControlException
Anomaly
KafkaCruiseControlException
public java.lang.String toString()