public interface WorkerMetricsProcessor
| 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.
|
void processWorkerMetrics(Map<String,Object> conf, WorkerMetrics metrics) throws MetricException
Process insertion of worker metrics. The implementation should be thread-safe.
conf - the supervisor configmetrics - the metrics to processMetricException - on errorvoid prepare(Map<String,Object> config) throws MetricException
Prepares the metric processor.
config - Storm config mapMetricException - on errorCopyright © 2021 The Apache Software Foundation. All rights reserved.