org.apache.ambari.server.topology

Class ClusterTopologyImpl

java.lang.Object

org.apache.ambari.server.topology.ClusterTopologyImpl

All Implemented Interfaces:

ClusterTopology

public class ClusterTopologyImpl
extends Object
implements ClusterTopology

Represents a cluster topology. Topology includes the the associated blueprint, cluster configuration and hostgroup -> host mapping.

Constructor Summary

Constructors

Constructor and Description
ClusterTopologyImpl(AmbariContext ambariContext, TopologyRequest topologyRequest)

Method Summary

Modifier and Type	Method and Description
void	addHostToTopology(String hostGroupName, String host) Add a new host to the topology.
Map<String,AdvisedConfiguration>	getAdvisedConfigurations()
Set<String>	getAllHosts()
AmbariContext	getAmbariContext()
Blueprint	getBlueprint() Get the blueprint associated with the cluster.
Long	getClusterId() Get the id of the cluster.
ConfigRecommendationStrategy	getConfigRecommendationStrategy()
Configuration	getConfiguration() Get the cluster scoped configuration for the cluster.
String	getDefaultPassword()
Collection<String>	getHostAssignmentsForComponent(String component) Get all hosts which are mapped to a host group which contains the specified component.
String	getHostGroupForHost(String hostname) Get the name of the host group which is mapped to the specified host.
Map<String,HostGroupInfo>	getHostGroupInfo() Get host group information.
Collection<String>	getHostGroupsForComponent(String component) Get the names of all of host groups which contain the specified component.
ProvisionAction	getProvisionAction()
boolean	hasHadoopCompatibleService()
RequestStatusResponse	installHost(String hostName, boolean skipInstallTaskCreate, boolean skipFailure) Install the specified host.
boolean	isClusterKerberosEnabled() Determine if the cluster is kerberos enabled.
boolean	isNameNodeHAEnabled() Determine if NameNode HA is enabled.
static boolean	isNameNodeHAEnabled(Map<String,Map<String,String>> configurationProperties)
boolean	isYarnResourceManagerHAEnabled() Determine if Yarn ResourceManager HA is enabled.
void	removeHost(String hostname) Removes host from stateful ClusterTopology
void	setClusterId(Long clusterId) Set the id of the cluster.
void	setConfigRecommendationStrategy(ConfigRecommendationStrategy strategy)
void	setProvisionAction(ProvisionAction provisionAction) Set request provision action : INSTALL vs INSTALL_AND_START
RequestStatusResponse	startHost(String hostName, boolean skipFailure) Start the specified host.
void	update(TopologyRequest topologyRequest) Update the existing topology based on the provided topology request.

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterTopologyImpl

public ClusterTopologyImpl(AmbariContext ambariContext,
                           TopologyRequest topologyRequest)
                    throws InvalidTopologyException

Throws:

InvalidTopologyException

Method Detail

update

public void update(TopologyRequest topologyRequest)
            throws InvalidTopologyException

Description copied from interface: ClusterTopology

Update the existing topology based on the provided topology request.

Specified by:

update in interface ClusterTopology

Parameters:

topologyRequest - request modifying the topology

Throws:

InvalidTopologyException - if the request specified invalid topology information or if making the requested changes would result in an invalid topology

getClusterId

public Long getClusterId()

Description copied from interface: ClusterTopology

Get the id of the cluster.

Specified by:

getClusterId in interface ClusterTopology

Returns:

cluster id

setClusterId

public void setClusterId(Long clusterId)

Description copied from interface: ClusterTopology

Set the id of the cluster.

Specified by:

setClusterId in interface ClusterTopology

Parameters:

clusterId - cluster id

getBlueprint

public Blueprint getBlueprint()

Description copied from interface: ClusterTopology

Get the blueprint associated with the cluster.

Specified by:

getBlueprint in interface ClusterTopology

Returns:

assocaited blueprint

getConfiguration

public Configuration getConfiguration()

Description copied from interface: ClusterTopology

Get the cluster scoped configuration for the cluster. This configuration has the blueprint cluster scoped configuration set as it's parent.

Specified by:

getConfiguration in interface ClusterTopology

Returns:

cluster scoped configuration

getHostGroupInfo

public Map<String,HostGroupInfo> getHostGroupInfo()

Description copied from interface: ClusterTopology

Get host group information.

Specified by:

getHostGroupInfo in interface ClusterTopology

Returns:

map of host group name to host group information

getHostGroupsForComponent

public Collection<String> getHostGroupsForComponent(String component)

Description copied from interface: ClusterTopology

Get the names of all of host groups which contain the specified component.

Specified by:

getHostGroupsForComponent in interface ClusterTopology

Parameters:

component - component name

Returns:

collection of host group names which contain the specified component

getHostGroupForHost

public String getHostGroupForHost(String hostname)

Description copied from interface: ClusterTopology

Get the name of the host group which is mapped to the specified host.

Specified by:

getHostGroupForHost in interface ClusterTopology

Parameters:

hostname - host name

Returns:

name of the host group which is mapped to the specified host or null if no group is mapped to the host

addHostToTopology

public void addHostToTopology(String hostGroupName,
                              String host)
                       throws InvalidTopologyException,
                              NoSuchHostGroupException

Description copied from interface: ClusterTopology

Add a new host to the topology.

Specified by:

addHostToTopology in interface ClusterTopology

Parameters:

hostGroupName - name of associated host group

host - name of host

Throws:

InvalidTopologyException - if the host being added is already registered to a different host group

NoSuchHostGroupException - if the specified host group is invalid

getAllHosts

public Set<String> getAllHosts()

Specified by:

getAllHosts in interface ClusterTopology

Returns:

all hosts in the topology

getHostAssignmentsForComponent

public Collection<String> getHostAssignmentsForComponent(String component)

Description copied from interface: ClusterTopology

Get all hosts which are mapped to a host group which contains the specified component. The host need only to be mapped to the hostgroup, not actually provisioned.

Specified by:

getHostAssignmentsForComponent in interface ClusterTopology

Parameters:

component - component name

Returns:

collection of hosts for the specified component; will not return null

isNameNodeHAEnabled

public boolean isNameNodeHAEnabled()

Description copied from interface: ClusterTopology

Determine if NameNode HA is enabled.

Specified by:

isNameNodeHAEnabled in interface ClusterTopology

Returns:

true if NameNode HA is enabled; false otherwise

isNameNodeHAEnabled

public static boolean isNameNodeHAEnabled(Map<String,Map<String,String>> configurationProperties)

isYarnResourceManagerHAEnabled

public boolean isYarnResourceManagerHAEnabled()

Description copied from interface: ClusterTopology

Determine if Yarn ResourceManager HA is enabled.

Specified by:

isYarnResourceManagerHAEnabled in interface ClusterTopology

Returns:

true if Yarn ResourceManager HA is enabled; false otherwise

isClusterKerberosEnabled

public boolean isClusterKerberosEnabled()

Description copied from interface: ClusterTopology

Determine if the cluster is kerberos enabled.

Specified by:

isClusterKerberosEnabled in interface ClusterTopology

Returns:

true if the cluster is kerberos enabled; false otherwise

installHost

public RequestStatusResponse installHost(String hostName,
                                         boolean skipInstallTaskCreate,
                                         boolean skipFailure)

Description copied from interface: ClusterTopology

Install the specified host.

Specified by:

installHost in interface ClusterTopology

Parameters:

hostName - host name

Returns:

install response

startHost

public RequestStatusResponse startHost(String hostName,
                                       boolean skipFailure)

Description copied from interface: ClusterTopology

Start the specified host.

Specified by:

startHost in interface ClusterTopology

Parameters:

hostName - host name

Returns:

start response

setConfigRecommendationStrategy

public void setConfigRecommendationStrategy(ConfigRecommendationStrategy strategy)

Specified by:

setConfigRecommendationStrategy in interface ClusterTopology

getConfigRecommendationStrategy

public ConfigRecommendationStrategy getConfigRecommendationStrategy()

Specified by:

getConfigRecommendationStrategy in interface ClusterTopology

getProvisionAction

public ProvisionAction getProvisionAction()

Specified by:

getProvisionAction in interface ClusterTopology

setProvisionAction

public void setProvisionAction(ProvisionAction provisionAction)

Description copied from interface: ClusterTopology

Set request provision action : INSTALL vs INSTALL_AND_START

Specified by:

setProvisionAction in interface ClusterTopology

Parameters:

provisionAction - @ProvisionAction

getAdvisedConfigurations

public Map<String,AdvisedConfiguration> getAdvisedConfigurations()

Specified by:

getAdvisedConfigurations in interface ClusterTopology

getAmbariContext

public AmbariContext getAmbariContext()

Specified by:

getAmbariContext in interface ClusterTopology

removeHost

public void removeHost(String hostname)

Description copied from interface: ClusterTopology

Removes host from stateful ClusterTopology

Specified by:

removeHost in interface ClusterTopology

getDefaultPassword

public String getDefaultPassword()

Specified by:

getDefaultPassword in interface ClusterTopology

hasHadoopCompatibleService

public boolean hasHadoopCompatibleService()

Specified by:

hasHadoopCompatibleService in interface ClusterTopology

Returns:

true if the topology contains any service with HCFS tag