public class LoggingClusterMetricsConsumer extends Object implements IClusterMetricsConsumer
Listens for cluster related metrics, dumps them to log
To use, edit the storm.yaml config file:
  storm.cluster.metrics.register:
    - class: "org.apache.storm.metrics.LoggingClusterMetricsConsumer"
IClusterMetricsConsumer.ClusterInfo, IClusterMetricsConsumer.SupervisorInfo| Modifier and Type | Field and Description | 
|---|---|
| static org.slf4j.Logger | LOG | 
| Constructor and Description | 
|---|
| LoggingClusterMetricsConsumer() | 
| 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) | 
public void prepare(Object registrationArgument)
prepare in interface IClusterMetricsConsumerpublic void handleDataPoints(IClusterMetricsConsumer.ClusterInfo clusterInfo, Collection<DataPoint> dataPoints)
handleDataPoints in interface IClusterMetricsConsumerpublic void handleDataPoints(IClusterMetricsConsumer.SupervisorInfo supervisorInfo, Collection<DataPoint> dataPoints)
handleDataPoints in interface IClusterMetricsConsumerpublic void cleanup()
cleanup in interface IClusterMetricsConsumerCopyright © 2019 The Apache Software Foundation. All Rights Reserved.