public class RocksDbStore extends Object implements MetricStore, AutoCloseable
MetricStore.ScanCallback| Constructor and Description |
|---|
RocksDbStore() |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Shutdown the store.
|
void |
insert(Metric metric)
Stores metrics in the store.
|
boolean |
populateValue(Metric metric)
Fill out the numeric values for a metric.
|
void |
prepare(Map<String,Object> config,
StormMetricsRegistry metricsRegistry)
Create metric store instance using the configurations provided via the config map.
|
void |
scan(FilterOptions filter,
MetricStore.ScanCallback scanCallback)
Scans all metrics in the store and returns the ones matching the specified filtering options.
|
public void prepare(Map<String,Object> config, StormMetricsRegistry metricsRegistry) throws MetricException
Create metric store instance using the configurations provided via the config map.
prepare in interface MetricStoreconfig - Storm config mapmetricsRegistry - The Nimbus daemon metrics registryMetricException - on preparation errorpublic void insert(Metric metric) throws MetricException
Stores metrics in the store.
insert in interface MetricStoremetric - Metric to storeMetricException - if database write failspublic boolean populateValue(Metric metric) throws MetricException
Fill out the numeric values for a metric.
populateValue in interface MetricStoremetric - Metric to populateMetricException - if read from database failspublic void close()
Shutdown the store.
close in interface AutoCloseableclose in interface MetricStorepublic void scan(FilterOptions filter, MetricStore.ScanCallback scanCallback) throws MetricException
Scans all metrics in the store and returns the ones matching the specified filtering options. Callback returns Metric class results.
scan in interface MetricStorefilter - options to filter byscanCallback - callback for each Metric foundMetricException - on errorCopyright © 2021 The Apache Software Foundation. All rights reserved.