Uses of Class
org.apache.storm.metricstore.MetricException
Packages that use MetricException
-
Uses of MetricException in org.apache.storm.metricstore
Methods in org.apache.storm.metricstore that throw MetricExceptionModifier and TypeMethodDescriptionstatic MetricStoreMetricStoreConfig.configure(Map<String, Object> conf, StormMetricsRegistry metricsRegistry) Configures metrics store (running on Nimbus) to use the class specified in the conf.static WorkerMetricsProcessorMetricStoreConfig.configureMetricProcessor(Map conf) Configures metric processor (running on supervisor) to use the class specified in the conf.voidStores a metric in the store.booleanMetricStore.populateValue(Metric metric) Fill out the numeric values for a metric.voidMetricStore.prepare(Map<String, Object> config, StormMetricsRegistry metricsRegistry) Create metric store instance using the configurations provided via the config map.voidvoidPrepares the metric processor.voidNimbusMetricProcessor.processWorkerMetrics(Map<String, Object> conf, WorkerMetrics metrics) voidWorkerMetricsProcessor.processWorkerMetrics(Map<String, Object> conf, WorkerMetrics metrics) Process insertion of worker metrics.voidMetricStore.scan(FilterOptions filter, MetricStore.ScanCallback scanCallback) Scans all metrics in the store and returns the ones matching the specified filtering options.voidMetric.setAggLevel(AggLevel aggLevel) Set the aggLevel.voidFilterOptions.setAggLevels(Set<AggLevel> levels) Set the aggregation levels to search for.Constructors in org.apache.storm.metricstore that throw MetricException -
Uses of MetricException in org.apache.storm.metricstore.rocksdb
Methods in org.apache.storm.metricstore.rocksdb that throw MetricExceptionModifier and TypeMethodDescriptionvoidStores metrics in the store.booleanRocksDbStore.populateValue(Metric metric) Fill out the numeric values for a metric.voidRocksDbStore.prepare(Map<String, Object> config, StormMetricsRegistry metricsRegistry) Create metric store instance using the configurations provided via the config map.voidStringMetadataCache.put(String s, org.apache.storm.metricstore.rocksdb.StringMetadata stringMetadata, boolean newEntry) Add the string metadata to the cache.voidWritableStringMetadataCache.put(String s, org.apache.storm.metricstore.rocksdb.StringMetadata stringMetadata, boolean newEntry) Add the string metadata to the cache.voidRocksDbStore.scan(FilterOptions filter, MetricStore.ScanCallback scanCallback) Scans all metrics in the store and returns the ones matching the specified filtering options.