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 Summary
Nested classes/interfaces inherited from interface org.apache.storm.metric.api.IClusterMetricsConsumer
IClusterMetricsConsumer.ClusterInfo, IClusterMetricsConsumer.SupervisorInfo
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
cleanup()
void
handleDataPoints
(IClusterMetricsConsumer.ClusterInfo clusterInfo, Collection<DataPoint> dataPoints) void
handleDataPoints
(IClusterMetricsConsumer.SupervisorInfo supervisorInfo, Collection<DataPoint> dataPoints) void
-
Field Details
-
LOG
public static final org.slf4j.Logger LOG
-
-
Constructor Details
-
LoggingClusterMetricsConsumer
public LoggingClusterMetricsConsumer()
-
-
Method Details
-
prepare
- Specified by:
prepare
in interfaceIClusterMetricsConsumer
-
handleDataPoints
public void handleDataPoints(IClusterMetricsConsumer.ClusterInfo clusterInfo, Collection<DataPoint> dataPoints) - Specified by:
handleDataPoints
in interfaceIClusterMetricsConsumer
-
handleDataPoints
public void handleDataPoints(IClusterMetricsConsumer.SupervisorInfo supervisorInfo, Collection<DataPoint> dataPoints) - Specified by:
handleDataPoints
in interfaceIClusterMetricsConsumer
-
cleanup
public void cleanup()- Specified by:
cleanup
in interfaceIClusterMetricsConsumer
-