org.apache.storm.perf.utils

Class BasicMetricsCollector

java.lang.Object

org.apache.storm.perf.utils.BasicMetricsCollector

public class BasicMetricsCollector
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BasicMetricsCollector.MetricsCollectorConfig
static class	BasicMetricsCollector.MetricsItem

Field Summary

Fields

Modifier and Type	Field and Description
static String	EXECUTORS
static String	SPOUT_ACKED
static String	SPOUT_AVG_COMPLETE_LATENCY
static String	SPOUT_AVG_LATENCY_FORMAT
static String	SPOUT_EXECUTORS
static String	SPOUT_MAX_COMPLETE_LATENCY
static String	SPOUT_MAX_LATENCY_FORMAT
static String	SPOUT_THROUGHPUT
static String	SPOUT_TRANSFERRED
static String	TASKS
static String	TIME
static String	TIME_FORMAT
static String	TOTAL_SLOTS
static String	TRANSFERRED
static String	USED_SLOTS
static String	WORKERS
static String	XSFER_RATE

Constructor Summary

Constructors

Constructor and Description
BasicMetricsCollector(org.apache.storm.LocalCluster localCluster, String topoName, Map stormConfig)
BasicMetricsCollector(Nimbus.Client client, String topoName, Map stormConfig)

Method Summary

Modifier and Type	Method and Description
void	close()
void	collect(org.apache.storm.LocalCluster localCluster)
void	collect(Nimbus.Client client)

Methods inherited from class java.lang.Object

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

Field Detail

TIME

public static final String TIME

See Also:

Constant Field Values

TIME_FORMAT

public static final String TIME_FORMAT

See Also:

Constant Field Values

TOTAL_SLOTS

public static final String TOTAL_SLOTS

See Also:

Constant Field Values

USED_SLOTS

public static final String USED_SLOTS

See Also:

Constant Field Values

WORKERS

public static final String WORKERS

See Also:

Constant Field Values

TASKS

public static final String TASKS

See Also:

Constant Field Values

EXECUTORS

public static final String EXECUTORS

See Also:

Constant Field Values

TRANSFERRED

public static final String TRANSFERRED

See Also:

Constant Field Values

XSFER_RATE

public static final String XSFER_RATE

See Also:

Constant Field Values

SPOUT_EXECUTORS

public static final String SPOUT_EXECUTORS

See Also:

Constant Field Values

SPOUT_TRANSFERRED

public static final String SPOUT_TRANSFERRED

See Also:

Constant Field Values

SPOUT_ACKED

public static final String SPOUT_ACKED

See Also:

Constant Field Values

SPOUT_THROUGHPUT

public static final String SPOUT_THROUGHPUT

See Also:

Constant Field Values

SPOUT_AVG_COMPLETE_LATENCY

public static final String SPOUT_AVG_COMPLETE_LATENCY

See Also:

Constant Field Values

SPOUT_AVG_LATENCY_FORMAT

public static final String SPOUT_AVG_LATENCY_FORMAT

See Also:

Constant Field Values

SPOUT_MAX_COMPLETE_LATENCY

public static final String SPOUT_MAX_COMPLETE_LATENCY

See Also:

Constant Field Values

SPOUT_MAX_LATENCY_FORMAT

public static final String SPOUT_MAX_LATENCY_FORMAT

See Also:

Constant Field Values

Constructor Detail

BasicMetricsCollector

public BasicMetricsCollector(Nimbus.Client client,
                             String topoName,
                             Map stormConfig)

BasicMetricsCollector

public BasicMetricsCollector(org.apache.storm.LocalCluster localCluster,
                             String topoName,
                             Map stormConfig)

Method Detail

collect

public void collect(Nimbus.Client client)

collect

public void collect(org.apache.storm.LocalCluster localCluster)

close

public void close()