org.apache.storm.stats

Class SpoutExecutorStats

java.lang.Object

org.apache.storm.stats.CommonStats

org.apache.storm.stats.SpoutExecutorStats

public class SpoutExecutorStats
extends CommonStats

Field Summary

Fields inherited from class org.apache.storm.stats.CommonStats

rate

Constructor Summary

Constructors

Constructor and Description
SpoutExecutorStats(int rate, int numStatBuckets)

Method Summary

Modifier and Type	Method and Description
void	cleanupStats()
MultiLatencyStatAndMetric	getCompleteLatencies()
ExecutorStats	renderStats()
void	spoutAckedTuple(String stream, long latencyMs, com.codahale.metrics.Counter ackedCounter)
void	spoutFailedTuple(String stream, long latencyMs, com.codahale.metrics.Counter failedCounter)

Methods inherited from class org.apache.storm.stats.CommonStats

emittedTuple, getAcked, getEmitted, getFailed, getRate, getTransferred, transferredTuples, valueStat, valueStat

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SpoutExecutorStats

public SpoutExecutorStats(int rate,
                          int numStatBuckets)

Method Detail

getCompleteLatencies

public MultiLatencyStatAndMetric getCompleteLatencies()

cleanupStats

public void cleanupStats()

Overrides:

cleanupStats in class CommonStats

spoutAckedTuple

public void spoutAckedTuple(String stream,
                            long latencyMs,
                            com.codahale.metrics.Counter ackedCounter)

spoutFailedTuple

public void spoutFailedTuple(String stream,
                             long latencyMs,
                             com.codahale.metrics.Counter failedCounter)

renderStats

public ExecutorStats renderStats()

Specified by:

renderStats in class CommonStats