Package org.apache.storm.stats
Class CommonStats
- java.lang.Object
-
- org.apache.storm.stats.CommonStats
-
- Direct Known Subclasses:
BoltExecutorStats,SpoutExecutorStats
public abstract class CommonStats extends Object
-
-
Field Summary
Fields Modifier and Type Field Description protected intrate
-
Constructor Summary
Constructors Constructor Description CommonStats(int rate, int numStatBuckets)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description voidcleanupStats()voidemittedTuple(String stream)MultiCountStatgetAcked()MultiCountStatgetEmitted()MultiCountStatgetFailed()intgetRate()MultiCountStatgetTransferred()abstract ExecutorStatsrenderStats()voidtransferredTuples(String stream, int amount)protected Map<String,Map<String,Long>>valueStat(MultiCountStat metric)protected Map<String,Map<String,Double>>valueStat(MultiLatencyStat metric)
-
-
-
Method Detail
-
getFailed
public MultiCountStat getFailed()
-
getAcked
public MultiCountStat getAcked()
-
getRate
public int getRate()
-
getEmitted
public MultiCountStat getEmitted()
-
getTransferred
public MultiCountStat getTransferred()
-
emittedTuple
public void emittedTuple(String stream)
-
transferredTuples
public void transferredTuples(String stream, int amount)
-
cleanupStats
public void cleanupStats()
-
renderStats
public abstract ExecutorStats renderStats()
-
-