Package org.apache.storm.metricstore
Class MetricStoreConfig
java.lang.Object
org.apache.storm.metricstore.MetricStoreConfig
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic MetricStore
configure
(Map<String, Object> conf, StormMetricsRegistry metricsRegistry) Configures metrics store (running on Nimbus) to use the class specified in the conf.static WorkerMetricsProcessor
configureMetricProcessor
(Map conf) Configures metric processor (running on supervisor) to use the class specified in the conf.
-
Constructor Details
-
MetricStoreConfig
public MetricStoreConfig()
-
-
Method Details
-
configure
public static MetricStore configure(Map<String, Object> conf, StormMetricsRegistry metricsRegistry) throws MetricExceptionConfigures metrics store (running on Nimbus) to use the class specified in the conf.- Parameters:
conf
- Storm config mapmetricsRegistry
- The Nimbus daemon metrics registry- Returns:
- MetricStore prepared store
- Throws:
MetricException
- on misconfiguration
-
configureMetricProcessor
Configures metric processor (running on supervisor) to use the class specified in the conf.- Parameters:
conf
- the supervisor config- Returns:
- WorkerMetricsProcessor prepared processor
- Throws:
MetricException
- on misconfiguration
-