Package org.apache.storm.metricstore
Class MetricStoreConfig
java.lang.Object
org.apache.storm.metricstore.MetricStoreConfig
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionstatic MetricStoreconfigure(Map<String, Object> conf, StormMetricsRegistry metricsRegistry) Configures metrics store (running on Nimbus) to use the class specified in the conf.static WorkerMetricsProcessorconfigureMetricProcessor(Map conf) Configures metric processor (running on supervisor) to use the class specified in the conf.
- 
Constructor Details- 
MetricStoreConfigpublic MetricStoreConfig()
 
- 
- 
Method Details- 
configurepublic 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 map
- metricsRegistry- The Nimbus daemon metrics registry
- Returns:
- MetricStore prepared store
- Throws:
- MetricException- on misconfiguration
 
- 
configureMetricProcessorConfigures 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
 
 
-