Package org.apache.storm.metrics2
Class TaskMetrics
- java.lang.Object
-
- org.apache.storm.metrics2.TaskMetrics
-
public class TaskMetrics extends Object
-
-
Constructor Summary
Constructors Constructor Description TaskMetrics(WorkerTopologyContext context, String componentId, Integer taskid, StormMetricRegistry metricRegistry, Map<String,Object> topoConf)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidboltAckedTuple(String sourceComponentId, String sourceStreamId, long latencyMs)voidboltExecuteTuple(String sourceComponentId, String sourceStreamId, long latencyMs)voidboltFailedTuple(String sourceComponentId, String sourceStreamId)voidemittedTuple(String streamId)voidsetCapacity(double capacity)voidspoutAckedTuple(String streamId, long latencyMs)voidspoutFailedTuple(String streamId)voidtransferredTuples(String streamId, int amount)
-
-
-
Constructor Detail
-
TaskMetrics
public TaskMetrics(WorkerTopologyContext context, String componentId, Integer taskid, StormMetricRegistry metricRegistry, Map<String,Object> topoConf)
-
-
Method Detail
-
setCapacity
public void setCapacity(double capacity)
-
spoutAckedTuple
public void spoutAckedTuple(String streamId, long latencyMs)
-
boltAckedTuple
public void boltAckedTuple(String sourceComponentId, String sourceStreamId, long latencyMs)
-
spoutFailedTuple
public void spoutFailedTuple(String streamId)
-
emittedTuple
public void emittedTuple(String streamId)
-
transferredTuples
public void transferredTuples(String streamId, int amount)
-
-