public class JMXPropertyProvider extends AbstractPropertyProvider
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 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.
|
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.
|
getComponentMetrics, getPropertyInfoMap, getPropertyInfoMap, substituteArgument, updateComponentMetricMap
checkConfigPropertyIds, checkPropertyIds, containsArguments, getPropertyIds, getRegexGroups, getRegExpKey, getRequestPropertyIds, isPatternKey, setResourceProperty
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
checkPropertyIds
public static final String TIMED_OUT_MSG
public static final String STORM_REST_API
protected static final org.slf4j.Logger LOG
protected long populateTimeout
public JMXPropertyProvider(Map<String,Map<String,PropertyInfo>> componentMetrics, StreamProvider streamProvider, JMXHostProvider jmxHostProvider, String clusterNamePropertyId, String hostNamePropertyId, String componentNamePropertyId, String statePropertyId, Set<String> healthyStates)
componentMetrics
- the map of supported metricsstreamProvider
- the stream providerjmxHostProvider
- the host mappingclusterNamePropertyId
- the cluster name property idhostNamePropertyId
- the host name property idcomponentNamePropertyId
- the component name property idstatePropertyId
- the state property idhealthyStates
- the set of healthy state valuespublic Set<Resource> populateResources(Set<Resource> resources, Request request, Predicate predicate) throws SystemException
PropertyProvider
resources
- the resources to be populatedrequest
- the request object which defines the desired set of propertiespredicate
- the predicate object which filters which resources are returnedSystemException
- thrown if resources cannot be populatedprotected void setPopulateTimeout(long populateTimeout)
populateTimeout
- the populate timeout valueprotected String getSpec(String protocol, String hostName, String port, String componentName)
protocol
- the protocol, one of http or httpshostName
- the host nameport
- the portCopyright © 2014. All rights reserved.