Package org.apache.storm.loadgen
Class LoadMetricsServer.Measurements
java.lang.Object
org.apache.storm.loadgen.LoadMetricsServer.Measurements
- Enclosing class:
- LoadMetricsServer
-
Constructor Summary
ConstructorDescriptionDefault Constructor.Measurements
(long uptimeSecs, long acked, long timeWindow, long failed, org.HdrHistogram.Histogram histo, double userMs, double sysMs, double gcMs, long memBytes, Set<String> topologyIds, long workers, long executors, long hosts, Map<String, String> congested, long skippedMaxSpoutMs, double uiCompleteLatency) Constructor. -
Method Summary
Modifier and TypeMethodDescriptionvoid
Add other to this.long
endTime()
long
getAcked()
double
long
double
long
long
double
long
getHosts()
double
getLatencyAtPercentile
(double percential, TimeUnit unit) double
double
getMaxLatency
(TimeUnit unit) double
getMeanLatency
(TimeUnit unit) double
getMemMb()
double
getMinLatency
(TimeUnit unit) double
getSkippedMaxSpout
(TimeUnit unit) double
getSysTime
(TimeUnit unit) double
double
getUiCompleteLatency
(TimeUnit unit) long
double
getUserTime
(TimeUnit unit) long
long
-
Constructor Details
-
Measurements
public Measurements(long uptimeSecs, long acked, long timeWindow, long failed, org.HdrHistogram.Histogram histo, double userMs, double sysMs, double gcMs, long memBytes, Set<String> topologyIds, long workers, long executors, long hosts, Map<String, String> congested, long skippedMaxSpoutMs, double uiCompleteLatency) Constructor.- Parameters:
histo
- latency histogram.userMs
- user CPU in ms.sysMs
- system CPU in ms.gcMs
- GC CPU in ms.
-
Measurements
public Measurements()Default Constructor.
-
-
Method Details
-
add
Add other to this.- Parameters:
other
- meaurements to add in.
-
getLatencyAtPercentile
-
getMinLatency
-
getMaxLatency
-
getMeanLatency
-
getLatencyStdDeviation
-
getUiCompleteLatency
-
getUserTime
-
getSysTime
-
getGc
-
getSkippedMaxSpout
-
getMemMb
public double getMemMb() -
getUptimeSecs
public long getUptimeSecs() -
getCompleted
public long getCompleted() -
getCompletedPerSec
public double getCompletedPerSec() -
getAcked
public long getAcked() -
getAckedPerSec
public double getAckedPerSec() -
getFailed
public long getFailed() -
startTime
public long startTime() -
endTime
public long endTime() -
getTimeWindow
public double getTimeWindow() -
getTopologyIds
-
getWorkers
public long getWorkers() -
getHosts
public long getHosts() -
getExecutors
public long getExecutors() -
getCongested
-