Package org.apache.storm.metrics2
Class TaskMetrics
java.lang.Object
org.apache.storm.metrics2.TaskMetrics
- 
Constructor SummaryConstructorsConstructorDescriptionTaskMetrics(WorkerTopologyContext context, String componentId, Integer taskid, StormMetricRegistry metricRegistry, Map<String, Object> topoConf) 
- 
Method SummaryModifier 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- 
TaskMetricspublic TaskMetrics(WorkerTopologyContext context, String componentId, Integer taskid, StormMetricRegistry metricRegistry, Map<String, Object> topoConf) 
 
- 
- 
Method Details- 
setCapacitypublic void setCapacity(double capacity) 
- 
spoutAckedTuple
- 
boltAckedTuple
- 
spoutFailedTuple
- 
boltFailedTuple
- 
emittedTuple
- 
transferredTuples
- 
boltExecuteTuple
 
-