org.apache.ambari.server.stack

Class MasterHostResolver

java.lang.Object

org.apache.ambari.server.stack.MasterHostResolver

public class MasterHostResolver
extends Object

Class that determines hosts that are active or standby for services that support HA

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MasterHostResolver.Service
protected static class	MasterHostResolver.Status Union of status for several services.

Constructor Summary

Constructors

Constructor and Description
MasterHostResolver(Cluster cluster, ConfigHelper configHelper, UpgradeContext upgradeContext) Constructor.

Method Summary

Modifier and Type	Method and Description
static Collection<Host>	getCandidateHosts(Cluster cluster, ExecuteHostType executeHostType, String serviceName, String componentName) Gets hosts which match the supplied criteria.
Cluster	getCluster() Gets the cluster that this instance of the MasterHostResolver is initialized with.
HostsType	getMasterAndHosts(String serviceName, String componentName) Get the master hostname of the given service and component.
String	getValueFromDesiredConfigurations(String configType, String propertyName) Find Config value for current Cluster using configType and propertyName
boolean	isNameNodeHA() Determine if HDFS is present and it has NameNode High Availability.
protected String	queryJmxBeanValue(String hostname, int port, String beanName, String attributeName, boolean asQuery)
protected String	queryJmxBeanValue(String hostname, int port, String beanName, String attributeName, boolean asQuery, boolean encrypted) Query the JMX attribute at http(s)://$server:$port/jmx?qry=$query or http(s)://$server:$port/jmx?get=$bean::$attribute

Methods inherited from class java.lang.Object

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

Constructor Detail

MasterHostResolver

public MasterHostResolver(Cluster cluster,
                          ConfigHelper configHelper,
                          UpgradeContext upgradeContext)

Constructor.

Parameters:

configHelper - Configuration Helper

upgradeContext - the upgrade context

Method Detail

getCluster

public Cluster getCluster()

Gets the cluster that this instance of the MasterHostResolver is initialized with.

Returns:

the cluster (not null).

getMasterAndHosts

public HostsType getMasterAndHosts(String serviceName,
                                   String componentName)

Get the master hostname of the given service and component.

Parameters:

serviceName - Service

componentName - Component

Returns:

The hostname that is the master of the service and component if successful, null otherwise.

getCandidateHosts

public static Collection<Host> getCandidateHosts(Cluster cluster,
                                                 ExecuteHostType executeHostType,
                                                 String serviceName,
                                                 String componentName)

Gets hosts which match the supplied criteria.

Parameters:

cluster -

executeHostType -

serviceName -

componentName -

Returns:

isNameNodeHA

public boolean isNameNodeHA()
                     throws org.apache.ambari.server.AmbariException

Determine if HDFS is present and it has NameNode High Availability.

Returns:

true if has NameNode HA, otherwise, false.

Throws:

org.apache.ambari.server.AmbariException

getValueFromDesiredConfigurations

public String getValueFromDesiredConfigurations(String configType,
                                                String propertyName)

Find Config value for current Cluster using configType and propertyName

Parameters:

configType - Config Type

propertyName - Property Name

Returns:

Value of property if present else null

queryJmxBeanValue

protected String queryJmxBeanValue(String hostname,
                                   int port,
                                   String beanName,
                                   String attributeName,
                                   boolean asQuery)

queryJmxBeanValue

protected String queryJmxBeanValue(String hostname,
                                   int port,
                                   String beanName,
                                   String attributeName,
                                   boolean asQuery,
                                   boolean encrypted)

Query the JMX attribute at http(s)://$server:$port/jmx?qry=$query or http(s)://$server:$port/jmx?get=$bean::$attribute

Parameters:

hostname - host name

port - port number

beanName - if asQuery is false, then search for this bean name

attributeName - if asQuery is false, then search for this attribute name

asQuery - whether to search bean or query

encrypted - true if using https instead of http.

Returns:

The jmx value.