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 IClusterMetricsConsumer
public void handleDataPoints(IClusterMetricsConsumer.ClusterInfo clusterInfo, Collection<DataPoint> dataPoints)
handleDataPoints
in interface IClusterMetricsConsumer
public void handleDataPoints(IClusterMetricsConsumer.SupervisorInfo supervisorInfo, Collection<DataPoint> dataPoints)
handleDataPoints
in interface IClusterMetricsConsumer
public void cleanup()
cleanup
in interface IClusterMetricsConsumer
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.