org.apache.ambari.server.controller.metrics.ganglia

Class GangliaReportPropertyProvider

java.lang.Object

org.apache.ambari.server.controller.internal.BaseProvider

org.apache.ambari.server.controller.internal.AbstractPropertyProvider

org.apache.ambari.server.controller.metrics.MetricsReportPropertyProvider

org.apache.ambari.server.controller.metrics.ganglia.GangliaReportPropertyProvider

All Implemented Interfaces:

PropertyProvider

public class GangliaReportPropertyProvider
extends MetricsReportPropertyProvider

Property provider implementation for a Ganglia source. This provider is specialized to pull metrics from existing Ganglia reports.

Field Summary

Fields inherited from class org.apache.ambari.server.controller.metrics.MetricsReportPropertyProvider

clusterNamePropertyId, configuration, DEFAULT_PADDING_METHOD, hostProvider, streamProvider

Constructor Summary

Constructors

Constructor and Description
GangliaReportPropertyProvider(Map<String,Map<String,PropertyInfo>> componentPropertyInfoMap, StreamProvider streamProvider, ComponentSSLConfiguration configuration, MetricHostProvider hostProvider, String clusterNamePropertyId)

Method Summary

Modifier and Type	Method and Description
protected String	getSpec(String clusterName, String report) Get the spec to locate the Ganglia stream from the given request info.
Set<Resource>	populateResources(Set<Resource> resources, Request request, Predicate predicate) Populate the given set of resource with any properties that this property provider can provide and return a populated set of resources.

Methods inherited from class org.apache.ambari.server.controller.metrics.MetricsReportPropertyProvider

createInstance

Methods inherited from class org.apache.ambari.server.controller.internal.AbstractPropertyProvider

checkAuthorizationForMetrics, checkPropertyCategory, getClustersNameFromResources, getClustersResourceId, getComponentMetrics, getPropertyInfoMap, getResourceTypeFromResources, getValue, isSupportedPropertyId, substituteArgument, updateComponentMetricMap, updatePropertyInfo, updatePropertyInfoMap

Methods inherited from class org.apache.ambari.server.controller.internal.BaseProvider

checkCategory, checkConfigPropertyIds, checkPropertyIds, containsArguments, getCategoryIds, getPropertyIds, getRegexEntry, getRegexGroups, getRequestPropertyIds, isPatternKey, isPropertyCategoryRequested, isPropertyEntryRequested, isPropertyRequested, setResourceProperty

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ambari.server.controller.spi.PropertyProvider

checkPropertyIds

Constructor Detail

GangliaReportPropertyProvider

public GangliaReportPropertyProvider(Map<String,Map<String,PropertyInfo>> componentPropertyInfoMap,
                                     StreamProvider streamProvider,
                                     ComponentSSLConfiguration configuration,
                                     MetricHostProvider hostProvider,
                                     String clusterNamePropertyId)

Method Detail

populateResources

public Set<Resource> populateResources(Set<Resource> resources,
                                       Request request,
                                       Predicate predicate)
                                throws SystemException

Description copied from interface: PropertyProvider

Populate the given set of resource with any properties that this property provider can provide and return a populated set of resources. The provider may drop resources from the original set if it determines that the don't meet the conditions of the predicate.

Parameters:

resources - the resources to be populated

request - the request object which defines the desired set of properties

predicate - the predicate object which filters which resources are returned

Returns:

the populated set of resources

Throws:

SystemException - thrown if resources cannot be populated

getSpec

protected String getSpec(String clusterName,
                         String report)
                  throws SystemException

Get the spec to locate the Ganglia stream from the given request info.

Parameters:

clusterName - the cluster name

report - the report

Returns:

the spec

Throws:

SystemException - if unable to ge the Ganglia Collector host name