Package org.apache.storm.loadgen
Class LoadMetricsServer.Measurements
java.lang.Object
org.apache.storm.loadgen.LoadMetricsServer.Measurements
- Enclosing class:
- LoadMetricsServer
-
Constructor Summary
ConstructorsConstructorDescriptionDefault 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 TypeMethodDescriptionvoidAdd other to this.longendTime()longgetAcked()doublelongdoublelonglongdoublelonggetHosts()doublegetLatencyAtPercentile(double percential, TimeUnit unit) doubledoublegetMaxLatency(TimeUnit unit) doublegetMeanLatency(TimeUnit unit) doublegetMemMb()doublegetMinLatency(TimeUnit unit) doublegetSkippedMaxSpout(TimeUnit unit) doublegetSysTime(TimeUnit unit) doubledoublegetUiCompleteLatency(TimeUnit unit) longdoublegetUserTime(TimeUnit unit) longlong
-
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
-