public class NimbusMetricProcessor extends Object implements WorkerMetricsProcessor
Implementation of WorkerMetricsProcessor that sends metric data to Nimbus for processing.
| Constructor and Description |
|---|
NimbusMetricProcessor() |
| Modifier and Type | Method and Description |
|---|---|
void |
prepare(Map<String,Object> config)
Prepares the metric processor.
|
void |
processWorkerMetrics(Map<String,Object> conf,
WorkerMetrics metrics)
Process insertion of worker metrics.
|
public void processWorkerMetrics(Map<String,Object> conf, WorkerMetrics metrics) throws MetricException
WorkerMetricsProcessorProcess insertion of worker metrics. The implementation should be thread-safe.
processWorkerMetrics in interface WorkerMetricsProcessorconf - the supervisor configmetrics - the metrics to processMetricException - on errorpublic void prepare(Map<String,Object> config) throws MetricException
WorkerMetricsProcessorPrepares the metric processor.
prepare in interface WorkerMetricsProcessorconfig - Storm config mapMetricException - on errorCopyright © 2021 The Apache Software Foundation. All rights reserved.