Uses of Class
org.apache.storm.metricstore.MetricException
-
Uses of MetricException in org.apache.storm.metricstore
Modifier and TypeMethodDescriptionstatic MetricStore
MetricStoreConfig.configure
(Map<String, Object> conf, StormMetricsRegistry metricsRegistry) Configures metrics store (running on Nimbus) to use the class specified in the conf.static WorkerMetricsProcessor
MetricStoreConfig.configureMetricProcessor
(Map conf) Configures metric processor (running on supervisor) to use the class specified in the conf.void
Stores a metric in the store.boolean
MetricStore.populateValue
(Metric metric) Fill out the numeric values for a metric.void
MetricStore.prepare
(Map<String, Object> config, StormMetricsRegistry metricsRegistry) Create metric store instance using the configurations provided via the config map.void
void
Prepares the metric processor.void
NimbusMetricProcessor.processWorkerMetrics
(Map<String, Object> conf, WorkerMetrics metrics) void
WorkerMetricsProcessor.processWorkerMetrics
(Map<String, Object> conf, WorkerMetrics metrics) Process insertion of worker metrics.void
MetricStore.scan
(FilterOptions filter, MetricStore.ScanCallback scanCallback) Scans all metrics in the store and returns the ones matching the specified filtering options.void
Metric.setAggLevel
(AggLevel aggLevel) Set the aggLevel.void
FilterOptions.setAggLevels
(Set<AggLevel> levels) Set the aggregation levels to search for. -
Uses of MetricException in org.apache.storm.metricstore.rocksdb
Modifier and TypeMethodDescriptionvoid
Stores metrics in the store.boolean
RocksDbStore.populateValue
(Metric metric) Fill out the numeric values for a metric.void
RocksDbStore.prepare
(Map<String, Object> config, StormMetricsRegistry metricsRegistry) Create metric store instance using the configurations provided via the config map.void
StringMetadataCache.put
(String s, org.apache.storm.metricstore.rocksdb.StringMetadata stringMetadata, boolean newEntry) Add the string metadata to the cache.void
WritableStringMetadataCache.put
(String s, org.apache.storm.metricstore.rocksdb.StringMetadata stringMetadata, boolean newEntry) Add the string metadata to the cache.void
RocksDbStore.scan
(FilterOptions filter, MetricStore.ScanCallback scanCallback) Scans all metrics in the store and returns the ones matching the specified filtering options.