Package org.apache.storm.metricstore

# Interface WorkerMetricsProcessor

All Known Implementing Classes:
  `NimbusMetricProcessor`

public interface WorkerMetricsProcessor

- ## Method Summary

  Modifier and Type
  Method
  Description
  `void`
  `prepare(Map<String,Object> config)`
  Prepares the metric processor.
  `void`
  `processWorkerMetrics(Map<String,Object> conf, WorkerMetrics metrics)`
  Process insertion of worker metrics.

- ## Method Details

  - ### processWorkerMetrics

    void processWorkerMetrics(Map<String,Object> conf, WorkerMetrics metrics) throws MetricException
    Process insertion of worker metrics. The implementation should be thread-safe.
    Parameters:
      `conf` - the supervisor config
      `metrics` - the metrics to process
    Throws:
      `MetricException` - on error

  - ### prepare

    void prepare(Map<String,Object> config) throws MetricException
    Prepares the metric processor.
    Parameters:
      `config` - Storm config map
    Throws:
      `MetricException` - on error