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