Package org.apache.storm.stats
Class BoltExecutorStats
- java.lang.Object
-
- org.apache.storm.stats.CommonStats
-
- org.apache.storm.stats.BoltExecutorStats
-
public class BoltExecutorStats extends CommonStats
-
-
Field Summary
-
Fields inherited from class org.apache.storm.stats.CommonStats
rate
-
-
Constructor Summary
Constructors Constructor Description BoltExecutorStats(int rate, int numStatBuckets)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidboltAckedTuple(String component, String stream, long latencyMs)voidboltExecuteTuple(String component, String stream, long latencyMs, long workerUptimeSecs, Task firstExecutorTask)voidboltFailedTuple(String component, String stream)voidcleanupStats()MultiCountStatgetExecuted()MultiLatencyStatgetExecuteLatencies()MultiLatencyStatgetProcessLatencies()ExecutorStatsrenderStats()-
Methods inherited from class org.apache.storm.stats.CommonStats
emittedTuple, getAcked, getEmitted, getFailed, getRate, getTransferred, transferredTuples, valueStat, valueStat
-
-
-
-
Method Detail
-
getExecuted
public MultiCountStat getExecuted()
-
getProcessLatencies
public MultiLatencyStat getProcessLatencies()
-
getExecuteLatencies
public MultiLatencyStat getExecuteLatencies()
-
cleanupStats
public void cleanupStats()
- Overrides:
cleanupStatsin classCommonStats
-
boltExecuteTuple
public void boltExecuteTuple(String component, String stream, long latencyMs, long workerUptimeSecs, Task firstExecutorTask)
-
renderStats
public ExecutorStats renderStats()
- Specified by:
renderStatsin classCommonStats
-
-