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