Package org.apache.storm.testing
Class ForwardingMetricsConsumer
java.lang.Object
org.apache.storm.testing.ForwardingMetricsConsumer
- All Implemented Interfaces:
- IMetricsConsumer
- 
Nested Class SummaryNested classes/interfaces inherited from interface org.apache.storm.metric.api.IMetricsConsumerIMetricsConsumer.DataPoint, IMetricsConsumer.TaskInfo
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoidcleanup()voidhandleDataPoints(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints) voidprepare(Map<String, Object> topoConf, Object registrationArgument, TopologyContext context, IErrorReporter errorReporter) 
- 
Constructor Details- 
ForwardingMetricsConsumerpublic ForwardingMetricsConsumer()
 
- 
- 
Method Details- 
preparepublic void prepare(Map<String, Object> topoConf, Object registrationArgument, TopologyContext context, IErrorReporter errorReporter) - Specified by:
- preparein interface- IMetricsConsumer
 
- 
handleDataPointspublic void handleDataPoints(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints) - Specified by:
- handleDataPointsin interface- IMetricsConsumer
 
- 
cleanuppublic void cleanup()- Specified by:
- cleanupin interface- IMetricsConsumer
 
 
-