Class RocksDbStore
java.lang.Object
org.apache.storm.metricstore.rocksdb.RocksDbStore
- All Implemented Interfaces:
- AutoCloseable,- MetricStore
- 
Nested Class SummaryNested classes/interfaces inherited from interface org.apache.storm.metricstore.MetricStoreMetricStore.ScanCallback
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoidclose()Shutdown the store.voidStores metrics in the store.booleanpopulateValue(Metric metric) Fill out the numeric values for a metric.voidprepare(Map<String, Object> config, StormMetricsRegistry metricsRegistry) Create metric store instance using the configurations provided via the config map.voidscan(FilterOptions filter, MetricStore.ScanCallback scanCallback) Scans all metrics in the store and returns the ones matching the specified filtering options.
- 
Constructor Details- 
RocksDbStorepublic RocksDbStore()
 
- 
- 
Method Details- 
preparepublic void prepare(Map<String, Object> config, StormMetricsRegistry metricsRegistry) throws MetricExceptionCreate metric store instance using the configurations provided via the config map.- Specified by:
- preparein interface- MetricStore
- Parameters:
- config- Storm config map
- metricsRegistry- The Nimbus daemon metrics registry
- Throws:
- MetricException- on preparation error
 
- 
insertStores metrics in the store.- Specified by:
- insertin interface- MetricStore
- Parameters:
- metric- Metric to store
- Throws:
- MetricException- if database write fails
 
- 
populateValueFill out the numeric values for a metric.- Specified by:
- populateValuein interface- MetricStore
- Parameters:
- metric- Metric to populate
- Returns:
- true if the metric was populated, false otherwise
- Throws:
- MetricException- if read from database fails
 
- 
closepublic void close()Shutdown the store.- Specified by:
- closein interface- AutoCloseable
- Specified by:
- closein interface- MetricStore
 
- 
scanpublic 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.- Specified by:
- scanin interface- MetricStore
- Parameters:
- filter- options to filter by
- scanCallback- callback for each Metric found
- Throws:
- MetricException- on error
 
 
-