Package org.apache.storm.metricstore
Class NimbusMetricProcessor
- java.lang.Object
-
- org.apache.storm.metricstore.NimbusMetricProcessor
-
- All Implemented Interfaces:
WorkerMetricsProcessor
public class NimbusMetricProcessor extends Object implements WorkerMetricsProcessor
Implementation of WorkerMetricsProcessor that sends metric data to Nimbus for processing.
-
-
Constructor Summary
Constructors Constructor Description NimbusMetricProcessor()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidprepare(Map<String,Object> config)Prepares the metric processor.voidprocessWorkerMetrics(Map<String,Object> conf, WorkerMetrics metrics)Process insertion of worker metrics.
-
-
-
Method Detail
-
processWorkerMetrics
public void processWorkerMetrics(Map<String,Object> conf, WorkerMetrics metrics) throws MetricException
Description copied from interface:WorkerMetricsProcessorProcess insertion of worker metrics. The implementation should be thread-safe.- Specified by:
processWorkerMetricsin interfaceWorkerMetricsProcessor- Parameters:
conf- the supervisor configmetrics- the metrics to process- Throws:
MetricException- on error
-
prepare
public void prepare(Map<String,Object> config) throws MetricException
Description copied from interface:WorkerMetricsProcessorPrepares the metric processor.- Specified by:
preparein interfaceWorkerMetricsProcessor- Parameters:
config- Storm config map- Throws:
MetricException- on error
-
-