Package org.apache.storm.stats
Class BoltExecutorStats
java.lang.Object
org.apache.storm.stats.CommonStats
org.apache.storm.stats.BoltExecutorStats
-
Field Summary
Fields inherited from class org.apache.storm.stats.CommonStats
rate -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidboltAckedTuple(String component, String stream, long latencyMs) voidboltExecuteTuple(String component, String stream, long latencyMs, long workerUptimeSecs, Task firstExecutorTask) voidboltFailedTuple(String component, String stream) voidMethods inherited from class org.apache.storm.stats.CommonStats
emittedTuple, getAcked, getEmitted, getFailed, getRate, getTransferred, transferredTuples, valueStat, valueStat
-
Constructor Details
-
BoltExecutorStats
public BoltExecutorStats(int rate, int numStatBuckets)
-
-
Method Details
-
getExecuted
-
getProcessLatencies
-
getExecuteLatencies
-
cleanupStats
public void cleanupStats()- Overrides:
cleanupStatsin classCommonStats
-
boltExecuteTuple
-
boltAckedTuple
-
boltFailedTuple
-
renderStats
- Specified by:
renderStatsin classCommonStats
-