org.apache.ambari.server.controller.internal

Class BlueprintConfigurationProcessor

java.lang.Object

org.apache.ambari.server.controller.internal.BlueprintConfigurationProcessor

public class BlueprintConfigurationProcessor
extends Object

Updates configuration properties based on cluster topology. This is done when exporting a blueprint and when a cluster is provisioned via a blueprint.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	BlueprintConfigurationProcessor.MultipleHostTopologyUpdater Topology based updater which replaces original host names (possibly more than one) contained in a property value with the host names which runs the associated component in the new cluster.
static interface	BlueprintConfigurationProcessor.PropertyUpdater Provides functionality to update a property value.

Field Summary

Fields

Modifier and Type	Field and Description
protected static Map<String,Map<String,BlueprintConfigurationProcessor.PropertyUpdater>>	singleHostTopologyUpdaters Single host topology updaters
static Map<String,Set<String>>	TEMPORARY_PROPERTIES_FOR_CLUSTER_DEPLOYMENT These properties are only required during deployment, and should be removed afterwards.

Constructor Summary

Constructors

Constructor and Description
BlueprintConfigurationProcessor(ClusterTopology clusterTopology)

Method Summary

Modifier and Type	Method and Description
void	doNameNodeHAUpdate() Perform export update processing for HA configuration for NameNodes.
void	doOozieServerHAUpdate() Perform export update processing for HA configuration for Oozie servers.
void	doUpdateForBlueprintExport(BlueprintExportType exportType) Update properties for blueprint export.
Set<String>	doUpdateForClusterCreate() Update properties for cluster creation.
void	doYarnResourceManagerHAUpdate() Perform export update processing for HA configuration for Yarn ResourceManagers.
Map<String,Map<String,BlueprintConfigurationProcessor.PropertyUpdater>>	getRemovePropertyUpdaters()
Set<String>	getRequiredHostGroups()
void	initRemovePropertyUpdaters()
protected void	setStackToolsAndFeatures(Configuration configuration, Set<String> configTypesUpdated) Sets the read-only properties for stack features & tools, overriding anything provided in the blueprint.

Methods inherited from class java.lang.Object

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

Field Detail

TEMPORARY_PROPERTIES_FOR_CLUSTER_DEPLOYMENT

public static final Map<String,Set<String>> TEMPORARY_PROPERTIES_FOR_CLUSTER_DEPLOYMENT

These properties are only required during deployment, and should be removed afterwards.

singleHostTopologyUpdaters

protected static final Map<String,Map<String,BlueprintConfigurationProcessor.PropertyUpdater>> singleHostTopologyUpdaters

Single host topology updaters

Constructor Detail

BlueprintConfigurationProcessor

public BlueprintConfigurationProcessor(ClusterTopology clusterTopology)

Method Detail

getRemovePropertyUpdaters

public Map<String,Map<String,BlueprintConfigurationProcessor.PropertyUpdater>> getRemovePropertyUpdaters()

initRemovePropertyUpdaters

public void initRemovePropertyUpdaters()

getRequiredHostGroups

public Set<String> getRequiredHostGroups()

doUpdateForClusterCreate

public Set<String> doUpdateForClusterCreate()
                                     throws ConfigurationTopologyException

Update properties for cluster creation. This involves updating topology related properties with concrete topology information.

Returns:

Set of config type names that were updated by this update call

Throws:

ConfigurationTopologyException

doUpdateForBlueprintExport

public void doUpdateForBlueprintExport(BlueprintExportType exportType)

Update properties for blueprint export. This involves converting concrete topology information to host groups.

doNameNodeHAUpdate

public void doNameNodeHAUpdate()

Perform export update processing for HA configuration for NameNodes. The HA NameNode property names are based on the nameservices defined when HA is enabled via the Ambari UI, so this method dynamically determines the property names, and registers PropertyUpdaters to handle the masking of host names in these configuration items.

doYarnResourceManagerHAUpdate

public void doYarnResourceManagerHAUpdate()

Perform export update processing for HA configuration for Yarn ResourceManagers. The HA ResourceManager property names are based on the ResourceManager names defined when HA is enabled via the Ambari UI, so this method dynamically determines the property names, and registers PropertyUpdaters to handle the masking of host names in these configuration items.

doOozieServerHAUpdate

public void doOozieServerHAUpdate()

Perform export update processing for HA configuration for Oozie servers. The properties used in Oozie HA are not defined in the stack, but need to be added at runtime during an HA deployment in order to support exporting/redeploying clusters with Oozie HA config.

setStackToolsAndFeatures

protected void setStackToolsAndFeatures(Configuration configuration,
                                        Set<String> configTypesUpdated)
                                 throws ConfigurationTopologyException

Sets the read-only properties for stack features & tools, overriding anything provided in the blueprint.

Parameters:

configuration - the configuration to update with values from the stack.

configTypesUpdated - the list of configuration types updated (cluster-env will be added to this).

Throws:

ConfigurationTopologyException