| 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.