public class WindowMetricsQueue
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static interface |
WindowMetricsQueue.MetricsAggregator |
Constructor and Description |
---|
WindowMetricsQueue(int scale,
long scaleBoundary,
java.util.function.Function scaleValue,
java.util.function.Function timestampValue,
WindowMetricsQueue.MetricsAggregator aggregatorTotal,
long timeWindow,
int countWindow) |
Modifier and Type | Method and Description |
---|---|
void |
add(java.lang.Object metric) |
void |
addMinMaxComparator(java.lang.String name,
java.util.Comparator comparator) |
void |
arrangeQueue() |
int |
getCountWindow() |
java.lang.Object |
getMaxMetric(java.lang.String name) |
long |
getMaxTimestamp() |
java.util.Map |
getMinMaxMetricMap() |
java.lang.Object |
getMinMetric(java.lang.String name) |
long |
getMinTimestamp() |
long |
getTimeWindow() |
java.lang.Object |
getTotal() |
int |
getTotalCount() |
long |
getTotalResetTime() |
void |
removeMinMaxComparator(java.lang.String name) |
void |
reset() |
void |
setCountWindow(int countWindow) |
void |
setTimeWindow(long timeWindow) |
public WindowMetricsQueue(int scale, long scaleBoundary, java.util.function.Function scaleValue, java.util.function.Function timestampValue, WindowMetricsQueue.MetricsAggregator aggregatorTotal, long timeWindow, int countWindow)
public void reset()
public long getTimeWindow()
public int getCountWindow()
public void setTimeWindow(long timeWindow)
public void setCountWindow(int countWindow)
public void addMinMaxComparator(java.lang.String name, java.util.Comparator comparator)
public void removeMinMaxComparator(java.lang.String name)
public java.lang.Object getMinMetric(java.lang.String name)
public java.lang.Object getMaxMetric(java.lang.String name)
public java.util.Map getMinMaxMetricMap()
public int getTotalCount()
public long getTotalResetTime()
public java.lang.Object getTotal()
public void add(java.lang.Object metric)
public void arrangeQueue()
public long getMaxTimestamp()
public long getMinTimestamp()
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.