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 Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
Prepares the metric processor.void
processWorkerMetrics
(Map<String, Object> conf, WorkerMetrics metrics) Process insertion of worker metrics.
-
Constructor Details
-
NimbusMetricProcessor
public NimbusMetricProcessor()
-
-
Method Details
-
processWorkerMetrics
public void processWorkerMetrics(Map<String, Object> conf, WorkerMetrics metrics) throws MetricExceptionDescription copied from interface:WorkerMetricsProcessor
Process insertion of worker metrics. The implementation should be thread-safe.- Specified by:
processWorkerMetrics
in interfaceWorkerMetricsProcessor
- Parameters:
conf
- the supervisor configmetrics
- the metrics to process- Throws:
MetricException
- on error
-
prepare
Description copied from interface:WorkerMetricsProcessor
Prepares the metric processor.- Specified by:
prepare
in interfaceWorkerMetricsProcessor
- Parameters:
config
- Storm config map- Throws:
MetricException
- on error
-