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