Package 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 Description static org.slf4j.LoggerLOG
-
Constructor Summary
Constructors Constructor Description LoggingClusterMetricsConsumer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidcleanup()voidhandleDataPoints(IClusterMetricsConsumer.ClusterInfo clusterInfo, Collection<DataPoint> dataPoints)voidhandleDataPoints(IClusterMetricsConsumer.SupervisorInfo supervisorInfo, Collection<DataPoint> dataPoints)voidprepare(Object registrationArgument)
-
-
-
Method Detail
-
prepare
public void prepare(Object registrationArgument)
- Specified by:
preparein interfaceIClusterMetricsConsumer
-
handleDataPoints
public void handleDataPoints(IClusterMetricsConsumer.ClusterInfo clusterInfo, Collection<DataPoint> dataPoints)
- Specified by:
handleDataPointsin interfaceIClusterMetricsConsumer
-
handleDataPoints
public void handleDataPoints(IClusterMetricsConsumer.SupervisorInfo supervisorInfo, Collection<DataPoint> dataPoints)
- Specified by:
handleDataPointsin interfaceIClusterMetricsConsumer
-
cleanup
public void cleanup()
- Specified by:
cleanupin interfaceIClusterMetricsConsumer
-
-