public class LoadMonitorState
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
LinearRegressionModelParameters.LinearRegressionModelState |
detailTrainingProgress() |
java.util.Map<java.lang.String,java.lang.Object> |
getJsonStructure(boolean verbose) |
static LoadMonitorState |
loading(int numValidSnapshotWindows,
java.util.SortedMap<java.lang.Long,java.lang.Float> monitoredSnapshotWindows,
int numValidMonitoredTopics,
int totalNumPartitions,
double loadingProgress) |
java.util.SortedMap<java.lang.Long,java.lang.Float> |
monitoredWindows() |
static double |
nanToZero(double v) |
static LoadMonitorState |
notStarted() |
int |
numValidPartitions() |
int |
numValidWindows() |
static LoadMonitorState |
paused(int numValidSnapshotWindows,
java.util.SortedMap<java.lang.Long,java.lang.Float> monitoredSnapshotWindows,
int numValidMonitoredTopics,
int totalNumPartitions,
java.util.Map<org.apache.kafka.common.TopicPartition,java.util.List<SampleExtrapolation>> sampleExtrapolations,
java.lang.String reasonOfLatestPauseOrResume) |
static LoadMonitorState |
running(int numValidSnapshotWindows,
java.util.SortedMap<java.lang.Long,java.lang.Float> partitionCoverageByWindows,
int numValidMonitoredTopics,
int totalNumPartitions,
java.util.Map<org.apache.kafka.common.TopicPartition,java.util.List<SampleExtrapolation>> sampleExtrapolations,
java.lang.String reasonOfLatestPauseOrResume) |
java.util.Map<org.apache.kafka.common.TopicPartition,java.util.List<SampleExtrapolation>> |
sampleExtrapolations() |
static LoadMonitorState |
sampling(int numValidSnapshotWindows,
java.util.SortedMap<java.lang.Long,java.lang.Float> monitoredSnapshotWindows,
int numValidMonitoredTopics,
int totalNumPartitions,
java.util.Map<org.apache.kafka.common.TopicPartition,java.util.List<SampleExtrapolation>> sampleExtrapolations) |
LoadMonitorTaskRunner.LoadMonitorTaskRunnerState |
state() |
java.lang.String |
toString() |
double |
validPartitionsRatio() |
public static LoadMonitorState notStarted()
public static LoadMonitorState running(int numValidSnapshotWindows, java.util.SortedMap<java.lang.Long,java.lang.Float> partitionCoverageByWindows, int numValidMonitoredTopics, int totalNumPartitions, java.util.Map<org.apache.kafka.common.TopicPartition,java.util.List<SampleExtrapolation>> sampleExtrapolations, java.lang.String reasonOfLatestPauseOrResume)
public static LoadMonitorState paused(int numValidSnapshotWindows, java.util.SortedMap<java.lang.Long,java.lang.Float> monitoredSnapshotWindows, int numValidMonitoredTopics, int totalNumPartitions, java.util.Map<org.apache.kafka.common.TopicPartition,java.util.List<SampleExtrapolation>> sampleExtrapolations, java.lang.String reasonOfLatestPauseOrResume)
public static LoadMonitorState sampling(int numValidSnapshotWindows, java.util.SortedMap<java.lang.Long,java.lang.Float> monitoredSnapshotWindows, int numValidMonitoredTopics, int totalNumPartitions, java.util.Map<org.apache.kafka.common.TopicPartition,java.util.List<SampleExtrapolation>> sampleExtrapolations)
public static LoadMonitorState loading(int numValidSnapshotWindows, java.util.SortedMap<java.lang.Long,java.lang.Float> monitoredSnapshotWindows, int numValidMonitoredTopics, int totalNumPartitions, double loadingProgress)
public java.util.Map<java.lang.String,java.lang.Object> getJsonStructure(boolean verbose)
public static double nanToZero(double v)
public java.lang.String toString()
toString
in class java.lang.Object
public LoadMonitorTaskRunner.LoadMonitorTaskRunnerState state()
public int numValidWindows()
public java.util.SortedMap<java.lang.Long,java.lang.Float> monitoredWindows()
public int numValidPartitions()
public double validPartitionsRatio()
public java.util.Map<org.apache.kafka.common.TopicPartition,java.util.List<SampleExtrapolation>> sampleExtrapolations()
public LinearRegressionModelParameters.LinearRegressionModelState detailTrainingProgress()