Class TaskMetrics

java.lang.Object
org.apache.storm.metrics2.TaskMetrics

public class TaskMetrics extends Object
  • Constructor Details

  • Method Details

    • 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)
    • boltFailedTuple

      public void boltFailedTuple(String sourceComponentId, String sourceStreamId)
    • emittedTuple

      public void emittedTuple(String streamId)
    • transferredTuples

      public void transferredTuples(String streamId, int amount)
    • boltExecuteTuple

      public void boltExecuteTuple(String sourceComponentId, String sourceStreamId, long latencyMs)