Class MetricStoreConfig

java.lang.Object
org.apache.storm.metricstore.MetricStoreConfig

public class MetricStoreConfig extends Object
  • Constructor Details

    • MetricStoreConfig

      public MetricStoreConfig()
  • Method Details

    • configure

      public static MetricStore configure(Map<String,Object> conf, StormMetricsRegistry metricsRegistry) throws MetricException
      Configures 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
    • configureMetricProcessor

      public static WorkerMetricsProcessor configureMetricProcessor(Map conf) throws MetricException
      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