org.apache.storm.perf.utils

Class MetricsSample

java.lang.Object

org.apache.storm.perf.utils.MetricsSample

public class MetricsSample
extends Object

Constructor Summary

Constructors

Constructor and Description
MetricsSample()

Method Summary

Modifier and Type	Method and Description
static MetricsSample	factory(org.apache.storm.LocalCluster localCluster, String topologyName)
static MetricsSample	factory(Nimbus.Client client, String topologyName)
int	getNumExecutors()
int	getNumSupervisors()
int	getNumTasks()
int	getNumWorkers()
long	getSampleTime()
long	getSpoutEmitted()
int	getSpoutExecutors()
long	getSpoutTransferred()
static TopologySummary	getTopologySummary(ClusterSummary cs, String name)
long	getTotalAcked()
long	getTotalEmitted()
long	getTotalFailed()
double	getTotalLatency()
int	getTotalSlots()
long	getTotalTransferred()
int	getUsedSlots()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MetricsSample

public MetricsSample()

Method Detail

factory

public static MetricsSample factory(Nimbus.Client client,
                                    String topologyName)
                             throws Exception

Throws:

Exception

factory

public static MetricsSample factory(org.apache.storm.LocalCluster localCluster,
                                    String topologyName)
                             throws Exception

Throws:

Exception

getTopologySummary

public static TopologySummary getTopologySummary(ClusterSummary cs,
                                                 String name)

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