Package org.apache.storm.metrics2
Class TaskMetrics
java.lang.Object
org.apache.storm.metrics2.TaskMetrics
-
Constructor Summary
ConstructorDescriptionTaskMetrics
(WorkerTopologyContext context, String componentId, Integer taskid, StormMetricRegistry metricRegistry, Map<String, Object> topoConf) -
Method Summary
Modifier and TypeMethodDescriptionvoid
boltAckedTuple
(String sourceComponentId, String sourceStreamId, long latencyMs) void
boltExecuteTuple
(String sourceComponentId, String sourceStreamId, long latencyMs) void
boltFailedTuple
(String sourceComponentId, String sourceStreamId) void
emittedTuple
(String streamId) void
setCapacity
(double capacity) void
spoutAckedTuple
(String streamId, long latencyMs) void
spoutFailedTuple
(String streamId) void
transferredTuples
(String streamId, int amount)
-
Constructor Details
-
TaskMetrics
public TaskMetrics(WorkerTopologyContext context, String componentId, Integer taskid, StormMetricRegistry metricRegistry, Map<String, Object> topoConf)
-
-
Method Details
-
setCapacity
public void setCapacity(double capacity) -
spoutAckedTuple
-
boltAckedTuple
-
spoutFailedTuple
-
boltFailedTuple
-
emittedTuple
-
transferredTuples
-
boltExecuteTuple
-