Package org.apache.storm.metricstore
Interface WorkerMetricsProcessor
- All Known Implementing Classes:
- NimbusMetricProcessor
public interface WorkerMetricsProcessor
- 
Method SummaryModifier and TypeMethodDescriptionvoidPrepares the metric processor.voidprocessWorkerMetrics(Map<String, Object> conf, WorkerMetrics metrics) Process insertion of worker metrics.
- 
Method Details- 
processWorkerMetricsProcess insertion of worker metrics. The implementation should be thread-safe.- Parameters:
- conf- the supervisor config
- metrics- the metrics to process
- Throws:
- MetricException- on error
 
- 
preparePrepares the metric processor.- Parameters:
- config- Storm config map
- Throws:
- MetricException- on error
 
 
-