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()