org.apache.storm.metric

Class LoggingClusterMetricsConsumer

java.lang.Object

org.apache.storm.metric.LoggingClusterMetricsConsumer

All Implemented Interfaces:

IClusterMetricsConsumer

public class LoggingClusterMetricsConsumer
extends Object
implements IClusterMetricsConsumer

Listens for cluster related metrics, dumps them to log.

To use, edit the storm.yaml config file: ```yaml storm.cluster.metrics.register: - class: "org.apache.storm.metrics.LoggingClusterMetricsConsumer" ```

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.storm.metric.api.IClusterMetricsConsumer

IClusterMetricsConsumer.ClusterInfo, IClusterMetricsConsumer.SupervisorInfo

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
LoggingClusterMetricsConsumer()

Method Summary

Modifier and Type	Method and Description
void	cleanup()
void	handleDataPoints(IClusterMetricsConsumer.ClusterInfo clusterInfo, Collection<DataPoint> dataPoints)
void	handleDataPoints(IClusterMetricsConsumer.SupervisorInfo supervisorInfo, Collection<DataPoint> dataPoints)
void	prepare(Object registrationArgument)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.slf4j.Logger LOG

Constructor Detail

LoggingClusterMetricsConsumer

public LoggingClusterMetricsConsumer()

Method Detail

prepare

public void prepare(Object registrationArgument)

Specified by:

prepare in interface IClusterMetricsConsumer

handleDataPoints

public void handleDataPoints(IClusterMetricsConsumer.ClusterInfo clusterInfo,
                             Collection<DataPoint> dataPoints)

Specified by:

handleDataPoints in interface IClusterMetricsConsumer

handleDataPoints

public void handleDataPoints(IClusterMetricsConsumer.SupervisorInfo supervisorInfo,
                             Collection<DataPoint> dataPoints)

Specified by:

handleDataPoints in interface IClusterMetricsConsumer

cleanup

public void cleanup()

Specified by:

cleanup in interface IClusterMetricsConsumer