Package org.apache.storm.metrics2
Class StormMetricRegistry
java.lang.Object
org.apache.storm.metrics2.StormMetricRegistry
- All Implemented Interfaces:
- MetricRegistryProvider
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptioncom.codahale.metrics.Countercom.codahale.metrics.Countercounter(String name, String topologyId, String componentId, Integer taskId, Integer workerPort, String streamId) com.codahale.metrics.Countercounter(String name, TopologyContext context) com.codahale.metrics.Countercounter(String name, WorkerTopologyContext context, String componentId, Integer taskId, String streamId) voidderegister(Set<com.codahale.metrics.Metric> toRemove) <T> com.codahale.metrics.Gauge<T><T> com.codahale.metrics.Gauge<T>gauge(String name, com.codahale.metrics.Gauge<T> gauge, String topologyId, String componentId, Integer taskId, Integer port) Deprecated.<T> com.codahale.metrics.Gauge<T>gauge(String name, com.codahale.metrics.Gauge<T> gauge, String topologyId, String componentId, String streamId, Integer taskId, Integer port) <T> com.codahale.metrics.Gauge<T>gauge(String name, com.codahale.metrics.Gauge<T> gauge, TopologyContext context) <T> SimpleGauge<T>gauge(T initialValue, String name, String topologyId, String componentId, Integer taskId, Integer port) intcom.codahale.metrics.MetricRegistrygetTaskCounters(int taskId) getTaskGauges(int taskId) getTaskHistograms(int taskId) getTaskMeters(int taskId) getTaskTimers(int taskId) com.codahale.metrics.Histogramhistogram(String name, TopologyContext context) com.codahale.metrics.Metermeter(String name, TopologyContext context) com.codahale.metrics.Metermeter(String name, WorkerTopologyContext context, String componentId, Integer taskId) com.codahale.metrics.Metermeter(String name, WorkerTopologyContext context, String componentId, Integer taskId, String streamId) voidmetricSet(String prefix, com.codahale.metrics.MetricSet set, TopologyContext context) rateCounter(String metricName, String componentId, int taskId) rateCounter(String metricName, String topologyId, String componentId, int taskId, int workerPort, String streamId) voidvoidstop()com.codahale.metrics.Timertimer(String name, TopologyContext context) 
- 
Constructor Details- 
StormMetricRegistrypublic StormMetricRegistry()
 
- 
- 
Method Details- 
rateCounterpublic RateCounter rateCounter(String metricName, String topologyId, String componentId, int taskId, int workerPort, String streamId) 
- 
rateCounter
- 
gauge
- 
gaugepublic <T> com.codahale.metrics.Gauge<T> gauge(String name, com.codahale.metrics.Gauge<T> gauge, TopologyContext context) 
- 
gauge@Deprecated public <T> com.codahale.metrics.Gauge<T> gauge(String name, com.codahale.metrics.Gauge<T> gauge, String topologyId, String componentId, Integer taskId, Integer port) Deprecated.
- 
gauge
- 
gauge
- 
meterpublic com.codahale.metrics.Meter meter(String name, WorkerTopologyContext context, String componentId, Integer taskId, String streamId) 
- 
meterpublic com.codahale.metrics.Meter meter(String name, WorkerTopologyContext context, String componentId, Integer taskId) 
- 
meter
- 
counterpublic com.codahale.metrics.Counter counter(String name, WorkerTopologyContext context, String componentId, Integer taskId, String streamId) 
- 
counter
- 
counter
- 
counter
- 
timer
- 
histogram
- 
metricSet
- 
deregister
- 
getTaskGauges
- 
getTaskCounters
- 
getTaskHistograms
- 
getTaskMeters
- 
getTaskTimers
- 
start
- 
stoppublic void stop()
- 
getRateCounterUpdateIntervalSecondspublic int getRateCounterUpdateIntervalSeconds()
- 
getRegistrypublic com.codahale.metrics.MetricRegistry getRegistry()- Specified by:
- getRegistryin interface- MetricRegistryProvider
 
- 
getTaskMetrics- Specified by:
- getTaskMetricsin interface- MetricRegistryProvider
 
 
-