Package org.apache.storm.metrics2
Class TaskMetrics
java.lang.Object
org.apache.storm.metrics2.TaskMetrics
-
Constructor Summary
ConstructorsConstructorDescriptionTaskMetrics(WorkerTopologyContext context, String componentId, Integer taskid, StormMetricRegistry metricRegistry, Map<String, Object> topoConf) -
Method Summary
Modifier and TypeMethodDescriptionvoidboltAckedTuple(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 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
-