| Modifier and Type | Method and Description | 
|---|---|
| void | LoadMetricsServer. handle(IMetricsConsumer.TaskInfo taskInfo,
      Collection<IMetricsConsumer.DataPoint> dataPoints,
      String topologyId) | 
| abstract void | HttpForwardingMetricsServer. handle(IMetricsConsumer.TaskInfo taskInfo,
      Collection<IMetricsConsumer.DataPoint> dataPoints,
      String topologyId) | 
| void | HttpForwardingMetricsConsumer. handleDataPoints(IMetricsConsumer.TaskInfo taskInfo,
                Collection<IMetricsConsumer.DataPoint> dataPoints) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | LoggingMetricsConsumer. handleDataPoints(IMetricsConsumer.TaskInfo taskInfo,
                Collection<IMetricsConsumer.DataPoint> dataPoints) | 
| Constructor and Description | 
|---|
| MetricsConsumerBolt(String consumerClassName,
                   Object registrationArgument,
                   int maxRetainMetricTuples,
                   org.apache.storm.shade.com.google.common.base.Predicate<IMetricsConsumer.DataPoint> filterPredicate,
                   DataPointExpander expander) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | IMetricsConsumer. handleDataPoints(IMetricsConsumer.TaskInfo taskInfo,
                Collection<IMetricsConsumer.DataPoint> dataPoints) | 
| Modifier and Type | Method and Description | 
|---|---|
| boolean | FilterByMetricName. apply(IMetricsConsumer.DataPoint dataPoint) | 
| Modifier and Type | Method and Description | 
|---|---|
| Collection<IMetricsConsumer.DataPoint> | DataPointExpander. expandDataPoint(IMetricsConsumer.DataPoint dataPoint) | 
| Collection<IMetricsConsumer.DataPoint> | DataPointExpander. expandDataPoints(Collection<IMetricsConsumer.DataPoint> dataPoints) | 
| Modifier and Type | Method and Description | 
|---|---|
| Collection<IMetricsConsumer.DataPoint> | DataPointExpander. expandDataPoint(IMetricsConsumer.DataPoint dataPoint) | 
| Modifier and Type | Method and Description | 
|---|---|
| Collection<IMetricsConsumer.DataPoint> | DataPointExpander. expandDataPoints(Collection<IMetricsConsumer.DataPoint> dataPoints) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | ForwardingMetricsConsumer. handleDataPoints(IMetricsConsumer.TaskInfo taskInfo,
                Collection<IMetricsConsumer.DataPoint> dataPoints) | 
Copyright © 2022 The Apache Software Foundation. All rights reserved.