Uses of Class
org.apache.storm.metricstore.MetricException
-
Packages that use MetricException Package Description org.apache.storm.metricstore org.apache.storm.metricstore.rocksdb -
-
Uses of MetricException in org.apache.storm.metricstore
Methods in org.apache.storm.metricstore that throw MetricException Modifier and Type Method Description static 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
MetricStore. insert(Metric metric)
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
NimbusMetricProcessor. prepare(Map<String,Object> config)
void
WorkerMetricsProcessor. prepare(Map<String,Object> config)
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.Constructors in org.apache.storm.metricstore that throw MetricException Constructor Description Metric(String name, Long timestamp, String topologyId, double value, String componentId, String executorId, String hostname, String streamId, int port, AggLevel aggLevel)
Metric constructor. -
Uses of MetricException in org.apache.storm.metricstore.rocksdb
Methods in org.apache.storm.metricstore.rocksdb that throw MetricException Modifier and Type Method Description void
RocksDbStore. insert(Metric metric)
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.
-