Uses of Class
org.apache.storm.metric.api.IMetricsConsumer.DataPoint
Package
Description
-
Uses of IMetricsConsumer.DataPoint in org.apache.storm.loadgen
Modifier and TypeMethodDescriptionabstract void
HttpForwardingMetricsServer.handle
(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints, String topologyId) void
LoadMetricsServer.handle
(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints, String topologyId) void
HttpForwardingMetricsConsumer.handleDataPoints
(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints) -
Uses of IMetricsConsumer.DataPoint in org.apache.storm.metric
Modifier and TypeMethodDescriptionvoid
LoggingMetricsConsumer.handleDataPoints
(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints) ModifierConstructorDescriptionMetricsConsumerBolt
(String consumerClassName, Object registrationArgument, int maxRetainMetricTuples, org.apache.storm.shade.com.google.common.base.Predicate<IMetricsConsumer.DataPoint> filterPredicate, DataPointExpander expander) -
Uses of IMetricsConsumer.DataPoint in org.apache.storm.metric.api
Modifier and TypeMethodDescriptionvoid
IMetricsConsumer.handleDataPoints
(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints) -
Uses of IMetricsConsumer.DataPoint in org.apache.storm.metric.filter
Modifier and TypeMethodDescriptionboolean
FilterByMetricName.apply
(IMetricsConsumer.DataPoint dataPoint) -
Uses of IMetricsConsumer.DataPoint in org.apache.storm.metric.util
Modifier and TypeMethodDescriptionDataPointExpander.expandDataPoint
(IMetricsConsumer.DataPoint dataPoint) DataPointExpander.expandDataPoints
(Collection<IMetricsConsumer.DataPoint> dataPoints) Modifier and TypeMethodDescriptionDataPointExpander.expandDataPoint
(IMetricsConsumer.DataPoint dataPoint) Modifier and TypeMethodDescriptionDataPointExpander.expandDataPoints
(Collection<IMetricsConsumer.DataPoint> dataPoints) -
Uses of IMetricsConsumer.DataPoint in org.apache.storm.testing
Modifier and TypeMethodDescriptionvoid
ForwardingMetricsConsumer.handleDataPoints
(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints)