Package org.apache.storm.metrics2
Class StormMetricRegistry
java.lang.Object
org.apache.storm.metrics2.StormMetricRegistry
- All Implemented Interfaces:
MetricRegistryProvider
-
Constructor Summary
Constructors -
Method Summary
Modifier 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
-
StormMetricRegistry
public StormMetricRegistry()
-
-
Method Details
-
rateCounter
public RateCounter rateCounter(String metricName, String topologyId, String componentId, int taskId, int workerPort, String streamId) -
rateCounter
-
gauge
-
gauge
public <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
-
meter
public com.codahale.metrics.Meter meter(String name, WorkerTopologyContext context, String componentId, Integer taskId, String streamId) -
meter
public com.codahale.metrics.Meter meter(String name, WorkerTopologyContext context, String componentId, Integer taskId) -
meter
-
counter
public 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
-
stop
public void stop() -
getRateCounterUpdateIntervalSeconds
public int getRateCounterUpdateIntervalSeconds() -
getRegistry
public com.codahale.metrics.MetricRegistry getRegistry()- Specified by:
getRegistryin interfaceMetricRegistryProvider
-
getTaskMetrics
- Specified by:
getTaskMetricsin interfaceMetricRegistryProvider
-