org.apache.ambari.server.controller.jmx

Class JMXPropertyProvider

java.lang.Object

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

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

org.apache.ambari.server.controller.jmx.JMXPropertyProvider

All Implemented Interfaces:

PropertyProvider

public class JMXPropertyProvider
extends AbstractPropertyProvider

Property provider implementation for JMX sources.

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG
protected long	populateTimeout The amount of time that this provider will wait for JMX metric values to be returned from the JMX sources.
static String	STORM_REST_API
static String	TIMED_OUT_MSG

Constructor Summary

Constructors

Constructor and Description
JMXPropertyProvider(Map<String,Map<String,PropertyInfo>> componentMetrics, StreamProvider streamProvider, JMXHostProvider jmxHostProvider, String clusterNamePropertyId, String hostNamePropertyId, String componentNamePropertyId, String statePropertyId, Set<String> healthyStates) Create a JMX property provider.

Method Summary

Modifier and Type	Method and Description
protected String	getSpec(String hostName, String port) Get the spec to locate the JMX stream from the given host and port
protected String	getSpec(String protocol, String hostName, String port, String componentName) Get the spec to locate the JMX stream from the given host and port
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.
protected void	setPopulateTimeout(long populateTimeout) Set the populate timeout value for this provider.

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

getComponentMetrics, getPropertyInfoMap, getPropertyInfoMap, substituteArgument, updateComponentMetricMap

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

checkConfigPropertyIds, checkPropertyIds, containsArguments, getPropertyIds, getRegexGroups, getRegExpKey, getRequestPropertyIds, isPatternKey, 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

Field Detail

TIMED_OUT_MSG

public static final String TIMED_OUT_MSG

See Also:

Constant Field Values

STORM_REST_API

public static final String STORM_REST_API

See Also:

Constant Field Values

LOG

protected static final org.slf4j.Logger LOG

populateTimeout

protected long populateTimeout

The amount of time that this provider will wait for JMX metric values to be returned from the JMX sources. If no results are returned for this amount of time then the request to populate the resources will fail.

Constructor Detail

JMXPropertyProvider

public JMXPropertyProvider(Map<String,Map<String,PropertyInfo>> componentMetrics,
                           StreamProvider streamProvider,
                           JMXHostProvider jmxHostProvider,
                           String clusterNamePropertyId,
                           String hostNamePropertyId,
                           String componentNamePropertyId,
                           String statePropertyId,
                           Set<String> healthyStates)

Create a JMX property provider.

Parameters:

componentMetrics - the map of supported metrics

streamProvider - the stream provider

jmxHostProvider - the host mapping

clusterNamePropertyId - the cluster name property id

hostNamePropertyId - the host name property id

componentNamePropertyId - the component name property id

statePropertyId - the state property id

healthyStates - the set of healthy state values

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

setPopulateTimeout

protected void setPopulateTimeout(long populateTimeout)

Set the populate timeout value for this provider.

Parameters:

populateTimeout - the populate timeout value

getSpec

protected String getSpec(String protocol,
                         String hostName,
                         String port,
                         String componentName)

Get the spec to locate the JMX stream from the given host and port

Parameters:

protocol - the protocol, one of http or https

hostName - the host name

port - the port

Returns:

the spec

getSpec

protected String getSpec(String hostName,
                         String port)

Get the spec to locate the JMX stream from the given host and port

Parameters:

hostName - the host name

port - the port

Returns:

the spec