Package org.apache.storm.stats
Class SpoutExecutorStats
java.lang.Object
org.apache.storm.stats.CommonStats
org.apache.storm.stats.SpoutExecutorStats
-
Field Summary
Fields inherited from class org.apache.storm.stats.CommonStats
rate
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
void
spoutAckedTuple
(String stream, long latencyMs) void
spoutFailedTuple
(String stream) Methods inherited from class org.apache.storm.stats.CommonStats
emittedTuple, getAcked, getEmitted, getFailed, getRate, getTransferred, transferredTuples, valueStat, valueStat
-
Constructor Details
-
SpoutExecutorStats
public SpoutExecutorStats(int rate, int numStatBuckets)
-
-
Method Details
-
getCompleteLatencies
-
cleanupStats
public void cleanupStats()- Overrides:
cleanupStats
in classCommonStats
-
spoutAckedTuple
-
spoutFailedTuple
-
renderStats
- Specified by:
renderStats
in classCommonStats
-