Package org.apache.storm.metric.api
Interface IMetricsConsumer
- All Known Implementing Classes:
ForwardingMetricsConsumer
,HttpForwardingMetricsConsumer
,LoggingMetricsConsumer
public interface IMetricsConsumer
-
Nested Class Summary
Modifier and TypeInterfaceDescriptionstatic class
static class
-
Method Summary
Modifier and TypeMethodDescriptionvoid
cleanup()
void
handleDataPoints
(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints) void
prepare
(Map<String, Object> topoConf, Object registrationArgument, TopologyContext context, IErrorReporter errorReporter)
-
Method Details
-
prepare
void prepare(Map<String, Object> topoConf, Object registrationArgument, TopologyContext context, IErrorReporter errorReporter) -
handleDataPoints
void handleDataPoints(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints) -
cleanup
void cleanup()
-