Package org.apache.storm.perf.utils

Class MetricsSample

java.lang.Object
org.apache.storm.perf.utils.MetricsSample
public class MetricsSample extends Object

  • Constructor Details

    • MetricsSample

      public MetricsSample()

  • Method Details

    • factory

      public static MetricsSample factory(Nimbus.Iface client, String topologyName) throws Exception
      Throws:
      Exception

    • getSampleTime

      public long getSampleTime()

    • getTotalTransferred

      public long getTotalTransferred()

    • getTotalEmitted

      public long getTotalEmitted()

    • getTotalAcked

      public long getTotalAcked()

    • getTotalFailed

      public long getTotalFailed()

    • getTotalLatency

      public double getTotalLatency()

    • getSpoutEmitted

      public long getSpoutEmitted()

    • getSpoutTransferred

      public long getSpoutTransferred()

    • getNumSupervisors

      public int getNumSupervisors()

    • getNumWorkers

      public int getNumWorkers()

    • getNumTasks

      public int getNumTasks()

    • getTotalSlots

      public int getTotalSlots()

    • getSpoutExecutors

      public int getSpoutExecutors()

    • getNumExecutors

      public int getNumExecutors()

    • getUsedSlots

      public int getUsedSlots()