org.apache.ambari.server.metrics.system.impl

Class DatabaseMetricsSource

java.lang.Object

org.apache.ambari.server.metrics.system.impl.AbstractMetricsSource

org.apache.ambari.server.metrics.system.impl.DatabaseMetricsSource

All Implemented Interfaces:

MetricsSource

public class DatabaseMetricsSource
extends AbstractMetricsSource

Field Summary

Fields inherited from class org.apache.ambari.server.metrics.system.impl.AbstractMetricsSource

sink

Constructor Summary

Constructors

Constructor and Description
DatabaseMetricsSource()

Method Summary

Modifier and Type	Method and Description
boolean	acceptMetric(String metricName) Accept a metric to be passed to Sink or not.
String	getConfigurationValue(String key, String defaultValue) Method to get Configuration value given key.
void	init(MetricsConfiguration metricsConfig, MetricsSink sink) Pass metrics sink to metrics source
void	publish(Map<String,Long> metricsMap) Method to publish metrics to Sink asynchronously.
void	start() Start the source

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DatabaseMetricsSource

public DatabaseMetricsSource()

Method Detail

init

public void init(MetricsConfiguration metricsConfig,
                 MetricsSink sink)

Description copied from class: AbstractMetricsSource

Pass metrics sink to metrics source

Specified by:

init in interface MetricsSource

Overrides:

init in class AbstractMetricsSource

start

public void start()

Description copied from interface: MetricsSource

Start the source

publish

public void publish(Map<String,Long> metricsMap)

Method to publish metrics to Sink asynchronously.

Parameters:

metricsMap - Map of metrics to be published to Sink

acceptMetric

public boolean acceptMetric(String metricName)

Accept a metric to be passed to Sink or not.

Parameters:

metricName -

Returns:

true/false

getConfigurationValue

public String getConfigurationValue(String key,
                                    String defaultValue)

Method to get Configuration value given key. An extra prefix is added internally.

Parameters:

key -

defaultValue -

Returns:

Value corresponding to key = dbMonitorPrefix + key