org.apache.storm.metrics2

Class TaskMetrics

java.lang.Object

org.apache.storm.metrics2.TaskMetrics

public class TaskMetrics
extends Object

Constructor Summary

Constructors

Constructor and Description
TaskMetrics(WorkerTopologyContext context, String componentId, Integer taskid, StormMetricRegistry metricRegistry)

Method Summary

Modifier and Type	Method and Description
com.codahale.metrics.Counter	getAcked(String streamId)
com.codahale.metrics.Counter	getEmitted(String streamId)
com.codahale.metrics.Counter	getFailed(String streamId)
com.codahale.metrics.Counter	getTransferred(String streamId)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskMetrics

public TaskMetrics(WorkerTopologyContext context,
                   String componentId,
                   Integer taskid,
                   StormMetricRegistry metricRegistry)

Method Detail

getAcked

public com.codahale.metrics.Counter getAcked(String streamId)

getFailed

public com.codahale.metrics.Counter getFailed(String streamId)

getEmitted

public com.codahale.metrics.Counter getEmitted(String streamId)

getTransferred

public com.codahale.metrics.Counter getTransferred(String streamId)