Package org.apache.storm.perf.utils

Class BasicMetricsCollector

java.lang.Object

org.apache.storm.perf.utils.BasicMetricsCollector

All Implemented Interfaces:

AutoCloseable

public class BasicMetricsCollector
extends Object
implements AutoCloseable

Nested Class Summary

Nested Classes

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

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
BasicMetricsCollector(String topoName, Map<String,Object> topoConfig)

Method Summary

Modifier and Type	Method	Description
void	close()
void	collect(Nimbus.Iface client)

Methods inherited from class java.lang.Object

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

Field Details

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 Details

BasicMetricsCollector

public BasicMetricsCollector(String topoName,
 Map<String,Object> topoConfig)

Method Details

collect

public void collect(Nimbus.Iface client)

close

public void close()

Specified by:

close in interface AutoCloseable