Package org.apache.storm.metricstore
Class NimbusMetricProcessor
java.lang.Object
org.apache.storm.metricstore.NimbusMetricProcessor
- All Implemented Interfaces:
- WorkerMetricsProcessor
Implementation of WorkerMetricsProcessor that sends metric data to Nimbus for processing.
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoidPrepares the metric processor.voidprocessWorkerMetrics(Map<String, Object> conf, WorkerMetrics metrics) Process insertion of worker metrics.
- 
Constructor Details- 
NimbusMetricProcessorpublic NimbusMetricProcessor()
 
- 
- 
Method Details- 
processWorkerMetricspublic void processWorkerMetrics(Map<String, Object> conf, WorkerMetrics metrics) throws MetricExceptionDescription copied from interface:WorkerMetricsProcessorProcess insertion of worker metrics. The implementation should be thread-safe.- Specified by:
- processWorkerMetricsin interface- WorkerMetricsProcessor
- Parameters:
- conf- the supervisor config
- metrics- the metrics to process
- Throws:
- MetricException- on error
 
- 
prepareDescription copied from interface:WorkerMetricsProcessorPrepares the metric processor.- Specified by:
- preparein interface- WorkerMetricsProcessor
- Parameters:
- config- Storm config map
- Throws:
- MetricException- on error
 
 
-