Package org.apache.storm.metric.api

# Interface IMetricsConsumer

All Known Implementing Classes:
  `ForwardingMetricsConsumer`, `HttpForwardingMetricsConsumer`, `LoggingMetricsConsumer`

public interface IMetricsConsumer

- ## Nested Class Summary

  Nested Classes
  Modifier and Type
  Interface
  Description
  `static class`
  `IMetricsConsumer.DataPoint`
  `static class`
  `IMetricsConsumer.TaskInfo`

- ## Method Summary

  Modifier and Type
  Method
  Description
  `void`
  `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()