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 and Description
protected int	rate

Constructor Summary

Constructors

Constructor and Description
CommonStats(int rate, int numStatBuckets)

Method Summary

Modifier and Type	Method and Description
void	cleanupStats()
void	emittedTuple(String stream, com.codahale.metrics.Counter emittedCounter)
MultiCountStatAndMetric	getAcked()
MultiCountStatAndMetric	getEmitted()
MultiCountStatAndMetric	getFailed()
int	getRate()
MultiCountStatAndMetric	getTransferred()
abstract ExecutorStats	renderStats()
void	transferredTuples(String stream, int amount, com.codahale.metrics.Counter transferredCounter)
protected Map<String,Map<String,Long>>	valueStat(MultiCountStatAndMetric metric)
protected Map<String,Map<String,Double>>	valueStat(MultiLatencyStatAndMetric metric)

Methods inherited from class java.lang.Object

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

Field Detail

rate

protected final int rate

Constructor Detail

CommonStats

public CommonStats(int rate,
                   int numStatBuckets)

Method Detail

getFailed

public MultiCountStatAndMetric getFailed()

getAcked

public MultiCountStatAndMetric getAcked()

getRate

public int getRate()

getEmitted

public MultiCountStatAndMetric getEmitted()

getTransferred

public MultiCountStatAndMetric getTransferred()

emittedTuple

public void emittedTuple(String stream,
                         com.codahale.metrics.Counter emittedCounter)

transferredTuples

public void transferredTuples(String stream,
                              int amount,
                              com.codahale.metrics.Counter transferredCounter)

cleanupStats

public void cleanupStats()

valueStat

protected Map<String,Map<String,Long>> valueStat(MultiCountStatAndMetric metric)

valueStat

protected Map<String,Map<String,Double>> valueStat(MultiLatencyStatAndMetric metric)

renderStats

public abstract ExecutorStats renderStats()