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 and Description
BoltExecutorStats(int rate, int numStatBuckets)

Method Summary

Modifier and Type	Method and Description
void	boltAckedTuple(String component, String stream, long latencyMs, com.codahale.metrics.Counter ackedCounter)
void	boltExecuteTuple(String component, String stream, long latencyMs)
void	boltFailedTuple(String component, String stream, long latencyMs, com.codahale.metrics.Counter failedCounter)
void	cleanupStats()
MultiCountStatAndMetric	getExecuted()
MultiLatencyStatAndMetric	getExecuteLatencies()
MultiLatencyStatAndMetric	getProcessLatencies()
ExecutorStats	renderStats()

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

BoltExecutorStats

public BoltExecutorStats(int rate,
                         int numStatBuckets)

Method Detail

getExecuted

public MultiCountStatAndMetric getExecuted()

getProcessLatencies

public MultiLatencyStatAndMetric getProcessLatencies()

getExecuteLatencies

public MultiLatencyStatAndMetric getExecuteLatencies()

cleanupStats

public void cleanupStats()

Overrides:

cleanupStats in class CommonStats

boltExecuteTuple

public void boltExecuteTuple(String component,
                             String stream,
                             long latencyMs)

boltAckedTuple

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

boltFailedTuple

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

renderStats

public ExecutorStats renderStats()

Specified by:

renderStats in class CommonStats