Package org.apache.storm.metric
Class LoggingClusterMetricsConsumer
java.lang.Object
org.apache.storm.metric.LoggingClusterMetricsConsumer
- All Implemented Interfaces:
- 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 SummaryNested classes/interfaces inherited from interface org.apache.storm.metric.api.IClusterMetricsConsumerIClusterMetricsConsumer.ClusterInfo, IClusterMetricsConsumer.SupervisorInfo
- 
Field SummaryFields
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoidcleanup()voidhandleDataPoints(IClusterMetricsConsumer.ClusterInfo clusterInfo, Collection<DataPoint> dataPoints) voidhandleDataPoints(IClusterMetricsConsumer.SupervisorInfo supervisorInfo, Collection<DataPoint> dataPoints) void
- 
Field Details- 
LOGpublic static final org.slf4j.Logger LOG
 
- 
- 
Constructor Details- 
LoggingClusterMetricsConsumerpublic LoggingClusterMetricsConsumer()
 
- 
- 
Method Details- 
prepare- Specified by:
- preparein interface- IClusterMetricsConsumer
 
- 
handleDataPointspublic void handleDataPoints(IClusterMetricsConsumer.ClusterInfo clusterInfo, Collection<DataPoint> dataPoints) - Specified by:
- handleDataPointsin interface- IClusterMetricsConsumer
 
- 
handleDataPointspublic void handleDataPoints(IClusterMetricsConsumer.SupervisorInfo supervisorInfo, Collection<DataPoint> dataPoints) - Specified by:
- handleDataPointsin interface- IClusterMetricsConsumer
 
- 
cleanuppublic void cleanup()- Specified by:
- cleanupin interface- IClusterMetricsConsumer
 
 
-