Package org.apache.storm.metricstore
Interface WorkerMetricsProcessor
-
- All Known Implementing Classes:
NimbusMetricProcessor
public interface WorkerMetricsProcessor
-
-
Method Summary
All Methods Instance Methods Abstract Methods 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 Detail
-
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 configmetrics
- 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
-
-