Package org.apache.storm.metric.api
Interface IMetricsConsumer
- All Known Implementing Classes:
- ForwardingMetricsConsumer,- HttpForwardingMetricsConsumer,- LoggingMetricsConsumer
public interface IMetricsConsumer
- 
Nested Class SummaryNested ClassesModifier and TypeInterfaceDescriptionstatic classstatic class
- 
Method SummaryModifier and TypeMethodDescriptionvoidcleanup()voidhandleDataPoints(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints) voidprepare(Map<String, Object> topoConf, Object registrationArgument, TopologyContext context, IErrorReporter errorReporter) 
- 
Method Details- 
preparevoid prepare(Map<String, Object> topoConf, Object registrationArgument, TopologyContext context, IErrorReporter errorReporter) 
- 
handleDataPointsvoid handleDataPoints(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints) 
- 
cleanupvoid cleanup()
 
-