Package org.apache.storm.metric.api
Interface IMetricsConsumer
- All Known Implementing Classes:
ForwardingMetricsConsumer,HttpForwardingMetricsConsumer,LoggingMetricsConsumer
public interface IMetricsConsumer
-
Nested Class Summary
Nested ClassesModifier and TypeInterfaceDescriptionstatic classstatic class -
Method Summary
Modifier and TypeMethodDescriptionvoidcleanup()voidhandleDataPoints(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints) voidprepare(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()
-