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"
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 © 2021 The Apache Software Foundation. All rights reserved.