org.apache.ambari.server.topology

Class AmbariContext

java.lang.Object

org.apache.ambari.server.topology.AmbariContext

public class AmbariContext
extends Object

Provides topology related information as well as access to the core Ambari functionality.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AmbariContext.TaskType

Constructor Summary

Constructors

Constructor and Description
AmbariContext()

Method Summary

Modifier and Type	Method and Description
void	createAmbariClusterResource(String clusterName, String stackName, String stackVersion, SecurityType securityType)
void	createAmbariHostResources(long clusterId, String hostName, Map<String,Collection<String>> components)
void	createAmbariResources(ClusterTopology topology, String clusterName, SecurityType securityType, String repoVersionString, Long repoVersionId)
void	createAmbariServiceAndComponentResources(ClusterTopology topology, String clusterName, StackId stackId, Long repositoryVersionId)
HostRoleCommand	createAmbariTask(long taskId, long requestId, long stageId, String component, String host, AmbariContext.TaskType type, boolean skipFailure)
HostRoleCommand	createAmbariTask(long requestId, long stageId, String component, String host, AmbariContext.TaskType type, boolean skipFailure)
List<ConfigurationRequest>	createConfigurationRequests(Map<String,Object> clusterProperties)
static ClusterController	getClusterController()
long	getClusterId(String clusterName)
String	getClusterName(long clusterId)
ConfigHelper	getConfigHelper() Gets an instance of ConfigHelper for classes which are not dependency injected.
static AmbariManagementController	getController()
Long	getNextRequestId()
PersistedState	getPersistedTopologyState()
HostRoleCommand	getPhysicalTask(long id)
Collection<HostRoleCommand>	getPhysicalTasks(Collection<Long> ids)
static void	init(HostRoleCommandFactory factory)
RequestStatusResponse	installHost(String hostName, String clusterName, Collection<String> skipInstallForComponents, Collection<String> dontSkipInstallForComponents, boolean skipFailure)
boolean	isClusterKerberosEnabled(long clusterId)
boolean	isHostRegisteredWithCluster(long clusterId, String host)
boolean	isTopologyResolved(long clusterId) Verifies if the given cluster has at least one desired configuration transitioned through TopologyManager.INITIAL -> ....
void	notifyAgentsAboutConfigsChanges(String clusterName)
void	persistInstallStateForUI(String clusterName, String stackName, String stackVersion) Persist cluster state for the ambari UI.
void	registerHostWithConfigGroup(String hostName, ClusterTopology topology, String groupName)
void	setConfigurationOnCluster(ClusterRequest clusterRequest)
RequestStatusResponse	startHost(String hostName, String clusterName, Collection<String> installOnlyComponents, boolean skipFailure)
void	waitForConfigurationResolution(String clusterName, Set<String> updatedConfigTypes) Verifies that all desired configurations have reached the resolved state before proceeding with the install

Methods inherited from class java.lang.Object

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

Constructor Detail

AmbariContext

public AmbariContext()

Method Detail

isClusterKerberosEnabled

public boolean isClusterKerberosEnabled(long clusterId)

createAmbariTask

public HostRoleCommand createAmbariTask(long requestId,
                                        long stageId,
                                        String component,
                                        String host,
                                        AmbariContext.TaskType type,
                                        boolean skipFailure)

createAmbariTask

public HostRoleCommand createAmbariTask(long taskId,
                                        long requestId,
                                        long stageId,
                                        String component,
                                        String host,
                                        AmbariContext.TaskType type,
                                        boolean skipFailure)

getPhysicalTask

public HostRoleCommand getPhysicalTask(long id)

getPhysicalTasks

public Collection<HostRoleCommand> getPhysicalTasks(Collection<Long> ids)

createAmbariResources

public void createAmbariResources(ClusterTopology topology,
                                  String clusterName,
                                  SecurityType securityType,
                                  String repoVersionString,
                                  Long repoVersionId)

createAmbariClusterResource

public void createAmbariClusterResource(String clusterName,
                                        String stackName,
                                        String stackVersion,
                                        SecurityType securityType)

createAmbariServiceAndComponentResources

public void createAmbariServiceAndComponentResources(ClusterTopology topology,
                                                     String clusterName,
                                                     StackId stackId,
                                                     Long repositoryVersionId)

createAmbariHostResources

public void createAmbariHostResources(long clusterId,
                                      String hostName,
                                      Map<String,Collection<String>> components)

getNextRequestId

public Long getNextRequestId()

getController

public static AmbariManagementController getController()

getClusterController

public static ClusterController getClusterController()

init

public static void init(HostRoleCommandFactory factory)

registerHostWithConfigGroup

public void registerHostWithConfigGroup(String hostName,
                                        ClusterTopology topology,
                                        String groupName)

installHost

public RequestStatusResponse installHost(String hostName,
                                         String clusterName,
                                         Collection<String> skipInstallForComponents,
                                         Collection<String> dontSkipInstallForComponents,
                                         boolean skipFailure)

startHost

public RequestStatusResponse startHost(String hostName,
                                       String clusterName,
                                       Collection<String> installOnlyComponents,
                                       boolean skipFailure)

persistInstallStateForUI

public void persistInstallStateForUI(String clusterName,
                                     String stackName,
                                     String stackVersion)

Persist cluster state for the ambari UI. Setting this state informs that UI that a cluster has been installed and started and that the monitoring screen for the cluster should be displayed to the user.

Parameters:

clusterName - cluster name

stackName - stack name

stackVersion - stack version

createConfigurationRequests

public List<ConfigurationRequest> createConfigurationRequests(Map<String,Object> clusterProperties)

setConfigurationOnCluster

public void setConfigurationOnCluster(ClusterRequest clusterRequest)

notifyAgentsAboutConfigsChanges

public void notifyAgentsAboutConfigsChanges(String clusterName)

waitForConfigurationResolution

public void waitForConfigurationResolution(String clusterName,
                                           Set<String> updatedConfigTypes)
                                    throws org.apache.ambari.server.AmbariException

Verifies that all desired configurations have reached the resolved state before proceeding with the install

Parameters:

clusterName - name of the cluster

updatedConfigTypes - set of config types that are required to be in the TOPOLOGY_RESOLVED state

Throws:

org.apache.ambari.server.AmbariException - upon any system-level error that occurs

isTopologyResolved

public boolean isTopologyResolved(long clusterId)

Verifies if the given cluster has at least one desired configuration transitioned through TopologyManager.INITIAL -> .... -> TopologyManager.TOPOLOGY_RESOLVED -> ....

Parameters:

clusterId - the identifier of the cluster to be checked

Returns:

true if the cluster

getPersistedTopologyState

public PersistedState getPersistedTopologyState()

isHostRegisteredWithCluster

public boolean isHostRegisteredWithCluster(long clusterId,
                                           String host)

getClusterId

public long getClusterId(String clusterName)
                  throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

getClusterName

public String getClusterName(long clusterId)
                      throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

getConfigHelper

public ConfigHelper getConfigHelper()

Gets an instance of ConfigHelper for classes which are not dependency injected.

Returns:

a ConfigHelper instance.