org.apache.ambari.server.controller

Class AmbariManagementControllerImpl

java.lang.Object

org.apache.ambari.server.controller.AmbariManagementControllerImpl

All Implemented Interfaces:

AmbariManagementController

public class AmbariManagementControllerImpl
extends Object
implements AmbariManagementController

Constructor Summary

Constructors

Constructor and Description
AmbariManagementControllerImpl(ActionManager actionManager, Clusters clusters, com.google.inject.Injector injector)

Method Summary

Modifier and Type	Method and Description
RequestStageContainer	addStages(RequestStageContainer requestStages, Cluster cluster, Map<String,String> requestProperties, Map<String,String> requestParameters, Map<State,List<Service>> changedServices, Map<State,List<ServiceComponent>> changedComponents, Map<String,Map<State,List<ServiceComponentHost>>> changedHosts, Collection<ServiceComponentHost> ignoredHosts, boolean runSmokeTest, boolean reconfigureClients) Add stages to the request.
RequestStatusResponse	createAction(ExecuteActionRequest actionRequest, Map<String,String> requestProperties) Create the action defined by the attributes in the given request object.
RequestStatusResponse	createAndPersistStages(Cluster cluster, Map<String,String> requestProperties, Map<String,String> requestParameters, Map<State,List<Service>> changedServices, Map<State,List<ServiceComponent>> changedComponents, Map<String,Map<State,List<ServiceComponentHost>>> changedHosts, Collection<ServiceComponentHost> ignoredHosts, boolean runSmokeTest, boolean reconfigureClients) Create and persist the request stages and return a response containing the associated request and resulting tasks.
void	createCluster(ClusterRequest request) Create the cluster defined by the attributes in the given request object.
void	createConfiguration(ConfigurationRequest request) Creates a configuration.
void	createHostComponents(Set<ServiceComponentHostRequest> requests) Create the host component defined by the attributes in the given request object.
void	createUsers(Set<UserRequest> requests) Creates users.
void	deleteCluster(ClusterRequest request) Delete the cluster identified by the given request object.
RequestStatusResponse	deleteHostComponents(Set<ServiceComponentHostRequest> requests) Delete the host component identified by the given request object.
void	deleteUsers(Set<UserRequest> requests) Deletes the users specified.
Map<String,Map<String,String>>	findConfigurationTagsWithOverrides(Cluster cluster, String hostName) Find configuration tags with applied overrides
ActionManager	getActionManager() Get the action manager for this management controller.
AmbariMetaInfo	getAmbariMetaInfo() Get the meta info for this management controller.
String	getAmbariServerURI(String path)
String	getAuthName() Get the authenticated user's name.
Clusters	getClusters() Get the clusters for this management controller.
Set<ClusterResponse>	getClusters(Set<ClusterRequest> requests) Get the clusters identified by the given request objects.
ConfigGroupFactory	getConfigGroupFactory() Get the config group factory for this management controller.
Set<ConfigurationResponse>	getConfigurations(Set<ConfigurationRequest> requests) Gets the configurations identified by the given request objects.
MaintenanceState	getEffectiveMaintenanceState(ServiceComponentHost sch) Gets the effective maintenance state for a host component
ExecutionScheduleManager	getExecutionScheduleManager() Get Execution Schedule Manager
String	getHealthyHost(Set<String> hostList) Return a healthy host if found otherwise any random host
Set<ServiceComponentHostResponse>	getHostComponents(Set<ServiceComponentHostRequest> requests) Get the host components identified by the given request objects.
String	getJavaHome() Getter for the java home, stored in ambari.properties
String	getJCEName() Getter for the jce name, stored in ambari.properties
String	getJDKName() Getter for the jdk name, stored in ambari.properties
String	getJdkResourceUrl() Getter for the url of JDK, stored at server resources folder
String	getJobTrackerHost(Cluster cluster) Get JobTracker hostname
String	getMysqljdbcUrl() Getter for the url of MySQL JDBC driver, stored at server resources folder
String	getOjdbcUrl() Getter for the url of Oracle JDBC driver, stored at server resources folder
Map<String,String>	getRcaParameters() Returns parameters for RCA database
Set<RepositoryResponse>	getRepositories(Set<RepositoryRequest> requests) Get repositories by stack name, version and operating system.
RequestExecutionFactory	getRequestExecutionFactory() Get the Factory to create Request schedules
Set<RootServiceComponentResponse>	getRootServiceComponents(Set<RootServiceComponentRequest> requests) Get all components of top-level services of Ambari, not related to certain cluster.
AbstractRootServiceResponseFactory	getRootServiceResponseFactory() Get the root service response factory for this management controller.
Set<RootServiceResponse>	getRootServices(Set<RootServiceRequest> requests) Get all top-level services of Ambari, not related to certain cluster.
String	getServerDB() Getter for the name of server database
ServiceComponentFactory	getServiceComponentFactory() Get the service component factory for this management controller.
ServiceFactory	getServiceFactory() Get the service factory for this management controller.
Set<StackServiceComponentResponse>	getStackComponents(Set<StackServiceComponentRequest> requests) Get components by stack name, version and service.
Set<StackConfigurationResponse>	getStackConfigurations(Set<StackConfigurationRequest> requests) Get configurations by stack name, version and service.
Set<OperatingSystemResponse>	getStackOperatingSystems(Set<OperatingSystemRequest> requests) Get operating systems by stack name, version.
Set<StackResponse>	getStacks(Set<StackRequest> requests) Get supported stacks.
Set<StackServiceResponse>	getStackServices(Set<StackServiceRequest> requests) Get repositories by stack name, version.
Set<StackVersionResponse>	getStackVersions(Set<StackVersionRequest> requests) Get supported stacks versions.
Set<TaskStatusResponse>	getTaskStatus(Set<TaskStatusRequest> requests) Gets the task status identified by the given request objects.
Set<UserResponse>	getUsers(Set<UserRequest> requests) Gets the users identified by the given request objects.
RequestStatusResponse	updateClusters(Set<ClusterRequest> requests, Map<String,String> requestProperties) Update the cluster identified by the given request object with the values carried by the given request object.
RequestStatusResponse	updateHostComponents(Set<ServiceComponentHostRequest> requests, Map<String,String> requestProperties, boolean runSmokeTest) Update the host component identified by the given request object with the values carried by the given request object.
void	updateRespositories(Set<RepositoryRequest> requests) Updates repositories by stack name, version and operating system.
RequestStatusResponse	updateStacks() Update stacks from the files at stackRoot.
void	updateUsers(Set<UserRequest> requests) Updates the users specified.

Methods inherited from class java.lang.Object

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

Constructor Detail

AmbariManagementControllerImpl

@Inject
public AmbariManagementControllerImpl(ActionManager actionManager,
                                              Clusters clusters,
                                              com.google.inject.Injector injector)
                                       throws Exception

Throws:

Exception

Method Detail

getAmbariServerURI

public String getAmbariServerURI(String path)

createCluster

public void createCluster(ClusterRequest request)
                   throws AmbariException

Description copied from interface: AmbariManagementController

Create the cluster defined by the attributes in the given request object.

Specified by:

createCluster in interface AmbariManagementController

Parameters:

request - the request object which defines the cluster to be created

Throws:

AmbariException - thrown if the cluster cannot be created

createHostComponents

public void createHostComponents(Set<ServiceComponentHostRequest> requests)
                          throws AmbariException

Description copied from interface: AmbariManagementController

Create the host component defined by the attributes in the given request object.

Specified by:

createHostComponents in interface AmbariManagementController

Parameters:

requests - the request object which defines the host component to be created

Throws:

AmbariException - thrown if the host component cannot be created

createConfiguration

public void createConfiguration(ConfigurationRequest request)
                         throws AmbariException

Description copied from interface: AmbariManagementController

Creates a configuration.

Specified by:

createConfiguration in interface AmbariManagementController

Parameters:

request - the request object which defines the configuration.

Throws:

AmbariException - when the configuration cannot be created.

createUsers

public void createUsers(Set<UserRequest> requests)
                 throws AmbariException

Description copied from interface: AmbariManagementController

Creates users.

Specified by:

createUsers in interface AmbariManagementController

Parameters:

requests - the request objects which defines the user.

Throws:

AmbariException - when the user cannot be created.

getEffectiveMaintenanceState

public MaintenanceState getEffectiveMaintenanceState(ServiceComponentHost sch)
                                              throws AmbariException

Description copied from interface: AmbariManagementController

Gets the effective maintenance state for a host component

Specified by:

getEffectiveMaintenanceState in interface AmbariManagementController

Parameters:

sch - the service component host

Returns:

the maintenance state

Throws:

AmbariException

updateClusters

public RequestStatusResponse updateClusters(Set<ClusterRequest> requests,
                                            Map<String,String> requestProperties)
                                     throws AmbariException

Description copied from interface: AmbariManagementController

Update the cluster identified by the given request object with the values carried by the given request object.

Specified by:

updateClusters in interface AmbariManagementController

Parameters:

requests - request objects which define which cluster to update and the values to set

requestProperties - request specific properties independent of resource

Returns:

a track action response

Throws:

AmbariException - thrown if the resource cannot be updated

getJobTrackerHost

public String getJobTrackerHost(Cluster cluster)

Description copied from interface: AmbariManagementController

Get JobTracker hostname

Specified by:

getJobTrackerHost in interface AmbariManagementController

findConfigurationTagsWithOverrides

public Map<String,Map<String,String>> findConfigurationTagsWithOverrides(Cluster cluster,
                                                                         String hostName)
                                                                  throws AmbariException

Description copied from interface: AmbariManagementController

Find configuration tags with applied overrides

Specified by:

findConfigurationTagsWithOverrides in interface AmbariManagementController

Parameters:

cluster - the cluster

hostName - the host name

Returns:

the configuration tags

Throws:

AmbariException - if configuration tags can not be obtained

getRequestExecutionFactory

public RequestExecutionFactory getRequestExecutionFactory()

Description copied from interface: AmbariManagementController

Get the Factory to create Request schedules

Specified by:

getRequestExecutionFactory in interface AmbariManagementController

Returns:

the request execution factory

getExecutionScheduleManager

public ExecutionScheduleManager getExecutionScheduleManager()

Description copied from interface: AmbariManagementController

Get Execution Schedule Manager

Specified by:

getExecutionScheduleManager in interface AmbariManagementController

createAndPersistStages

public RequestStatusResponse createAndPersistStages(Cluster cluster,
                                                    Map<String,String> requestProperties,
                                                    Map<String,String> requestParameters,
                                                    Map<State,List<Service>> changedServices,
                                                    Map<State,List<ServiceComponent>> changedComponents,
                                                    Map<String,Map<State,List<ServiceComponentHost>>> changedHosts,
                                                    Collection<ServiceComponentHost> ignoredHosts,
                                                    boolean runSmokeTest,
                                                    boolean reconfigureClients)
                                             throws AmbariException

Description copied from interface: AmbariManagementController

Create and persist the request stages and return a response containing the associated request and resulting tasks.

Specified by:

createAndPersistStages in interface AmbariManagementController

Parameters:

cluster - the cluster

requestProperties - the request properties

requestParameters - the request parameters; may be null

changedServices - the services being changed; may be null

changedComponents - the components being changed

changedHosts - the hosts being changed

ignoredHosts - the hosts to be ignored

runSmokeTest - indicates whether or not the smoke tests should be run

reconfigureClients - indicates whether or not the clients should be reconfigured

Returns:

the request response

Throws:

AmbariException - is thrown if the stages can not be created

addStages

public RequestStageContainer addStages(RequestStageContainer requestStages,
                                       Cluster cluster,
                                       Map<String,String> requestProperties,
                                       Map<String,String> requestParameters,
                                       Map<State,List<Service>> changedServices,
                                       Map<State,List<ServiceComponent>> changedComponents,
                                       Map<String,Map<State,List<ServiceComponentHost>>> changedHosts,
                                       Collection<ServiceComponentHost> ignoredHosts,
                                       boolean runSmokeTest,
                                       boolean reconfigureClients)
                                throws AmbariException

Description copied from interface: AmbariManagementController

Add stages to the request.

Specified by:

addStages in interface AmbariManagementController

Parameters:

requestStages - Stages currently associated with request

cluster - cluster being acted on

requestProperties - the request properties

requestParameters - the request parameters; may be null

changedServices - the services being changed; may be null

changedComponents - the components being changed

changedHosts - the hosts being changed

ignoredHosts - the hosts to be ignored

runSmokeTest - indicates whether or not the smoke tests should be run

reconfigureClients - indicates whether or not the clients should be reconfigured

Returns:

request stages

Throws:

AmbariException - if stages can't be created

updateHostComponents

public RequestStatusResponse updateHostComponents(Set<ServiceComponentHostRequest> requests,
                                                  Map<String,String> requestProperties,
                                                  boolean runSmokeTest)
                                           throws AmbariException

Description copied from interface: AmbariManagementController

Update the host component identified by the given request object with the values carried by the given request object.

Specified by:

updateHostComponents in interface AmbariManagementController

Parameters:

requests - the request object which defines which host component to update and the values to set

requestProperties - the request properties

runSmokeTest - indicates whether or not to run a smoke test

Returns:

a track action response

Throws:

AmbariException - thrown if the resource cannot be updated

updateUsers

public void updateUsers(Set<UserRequest> requests)
                 throws AmbariException

Description copied from interface: AmbariManagementController

Updates the users specified.

Specified by:

updateUsers in interface AmbariManagementController

Parameters:

requests - the users to modify

Throws:

AmbariException - if the resources cannot be updated

deleteCluster

public void deleteCluster(ClusterRequest request)
                   throws AmbariException

Description copied from interface: AmbariManagementController

Delete the cluster identified by the given request object.

Specified by:

deleteCluster in interface AmbariManagementController

Parameters:

request - the request object which identifies which cluster to delete

Throws:

AmbariException - thrown if the resource cannot be deleted

deleteHostComponents

public RequestStatusResponse deleteHostComponents(Set<ServiceComponentHostRequest> requests)
                                           throws AmbariException

Description copied from interface: AmbariManagementController

Delete the host component identified by the given request object.

Specified by:

deleteHostComponents in interface AmbariManagementController

Parameters:

requests - the request object which identifies which host component to delete

Returns:

a track action response

Throws:

AmbariException - thrown if the resource cannot be deleted

deleteUsers

public void deleteUsers(Set<UserRequest> requests)
                 throws AmbariException

Description copied from interface: AmbariManagementController

Deletes the users specified.

Specified by:

deleteUsers in interface AmbariManagementController

Parameters:

requests - the users to delete

Throws:

AmbariException - if the resources cannot be deleted

getTaskStatus

public Set<TaskStatusResponse> getTaskStatus(Set<TaskStatusRequest> requests)
                                      throws AmbariException

Description copied from interface: AmbariManagementController

Gets the task status identified by the given request objects.

Specified by:

getTaskStatus in interface AmbariManagementController

Parameters:

requests - the request objects

Returns:

a set of task status responses

Throws:

AmbariException - if the configurations could not be read

getClusters

public Set<ClusterResponse> getClusters(Set<ClusterRequest> requests)
                                 throws AmbariException

Description copied from interface: AmbariManagementController

Get the clusters identified by the given request objects.

Specified by:

getClusters in interface AmbariManagementController

Parameters:

requests - the request objects which identify the clusters to be returned

Returns:

a set of cluster responses

Throws:

AmbariException - thrown if the resource cannot be read

getHostComponents

public Set<ServiceComponentHostResponse> getHostComponents(Set<ServiceComponentHostRequest> requests)
                                                    throws AmbariException

Description copied from interface: AmbariManagementController

Get the host components identified by the given request objects.

Specified by:

getHostComponents in interface AmbariManagementController

Parameters:

requests - the request objects which identify the host components to be returned

Returns:

a set of host component responses

Throws:

AmbariException - thrown if the resource cannot be read

getConfigurations

public Set<ConfigurationResponse> getConfigurations(Set<ConfigurationRequest> requests)
                                             throws AmbariException

Description copied from interface: AmbariManagementController

Gets the configurations identified by the given request objects.

Specified by:

getConfigurations in interface AmbariManagementController

Parameters:

requests - the request objects

Returns:

a set of configuration responses

Throws:

AmbariException - if the configurations could not be read

getUsers

public Set<UserResponse> getUsers(Set<UserRequest> requests)
                           throws AmbariException

Description copied from interface: AmbariManagementController

Gets the users identified by the given request objects.

Specified by:

getUsers in interface AmbariManagementController

Parameters:

requests - the request objects

Returns:

a set of user responses

Throws:

AmbariException - if the users could not be read

getHealthyHost

public String getHealthyHost(Set<String> hostList)
                      throws AmbariException

Description copied from interface: AmbariManagementController

Return a healthy host if found otherwise any random host

Specified by:

getHealthyHost in interface AmbariManagementController

Throws:

AmbariException

createAction

public RequestStatusResponse createAction(ExecuteActionRequest actionRequest,
                                          Map<String,String> requestProperties)
                                   throws AmbariException

Description copied from interface: AmbariManagementController

Create the action defined by the attributes in the given request object.

Specified by:

createAction in interface AmbariManagementController

Parameters:

actionRequest - the request object which defines the action to be created

requestProperties - the request properties

Throws:

AmbariException - thrown if the action cannot be created

getStacks

public Set<StackResponse> getStacks(Set<StackRequest> requests)
                             throws AmbariException

Description copied from interface: AmbariManagementController

Get supported stacks.

Specified by:

getStacks in interface AmbariManagementController

Parameters:

requests - the stacks

Returns:

a set of stacks responses

Throws:

AmbariException - if the resources cannot be read

updateStacks

public RequestStatusResponse updateStacks()
                                   throws AmbariException

Description copied from interface: AmbariManagementController

Update stacks from the files at stackRoot.

Specified by:

updateStacks in interface AmbariManagementController

Returns:

a track action response

Throws:

AmbariException - if

getRepositories

public Set<RepositoryResponse> getRepositories(Set<RepositoryRequest> requests)
                                        throws AmbariException

Description copied from interface: AmbariManagementController

Get repositories by stack name, version and operating system.

Specified by:

getRepositories in interface AmbariManagementController

Parameters:

requests - the repositories

Returns:

a set of repositories

Throws:

AmbariException - if the resources cannot be read

updateRespositories

public void updateRespositories(Set<RepositoryRequest> requests)
                         throws AmbariException

Description copied from interface: AmbariManagementController

Updates repositories by stack name, version and operating system.

Specified by:

updateRespositories in interface AmbariManagementController

Parameters:

requests - the repositories

Throws:

AmbariException

getStackVersions

public Set<StackVersionResponse> getStackVersions(Set<StackVersionRequest> requests)
                                           throws AmbariException

Description copied from interface: AmbariManagementController

Get supported stacks versions.

Specified by:

getStackVersions in interface AmbariManagementController

Parameters:

requests - the stacks versions

Returns:

a set of stacks versions responses

Throws:

AmbariException - if the resources cannot be read

getStackServices

public Set<StackServiceResponse> getStackServices(Set<StackServiceRequest> requests)
                                           throws AmbariException

Description copied from interface: AmbariManagementController

Get repositories by stack name, version.

Specified by:

getStackServices in interface AmbariManagementController

Parameters:

requests - the services

Returns:

a set of services

Throws:

AmbariException - if the resources cannot be read

getStackConfigurations

public Set<StackConfigurationResponse> getStackConfigurations(Set<StackConfigurationRequest> requests)
                                                       throws AmbariException

Description copied from interface: AmbariManagementController

Get configurations by stack name, version and service.

Specified by:

getStackConfigurations in interface AmbariManagementController

Parameters:

requests - the configurations

Returns:

a set of configurations

Throws:

AmbariException - if the resources cannot be read

getStackComponents

public Set<StackServiceComponentResponse> getStackComponents(Set<StackServiceComponentRequest> requests)
                                                      throws AmbariException

Description copied from interface: AmbariManagementController

Get components by stack name, version and service.

Specified by:

getStackComponents in interface AmbariManagementController

Parameters:

requests - the components

Returns:

a set of components

Throws:

AmbariException - if the resources cannot be read

getStackOperatingSystems

public Set<OperatingSystemResponse> getStackOperatingSystems(Set<OperatingSystemRequest> requests)
                                                      throws AmbariException

Description copied from interface: AmbariManagementController

Get operating systems by stack name, version.

Specified by:

getStackOperatingSystems in interface AmbariManagementController

Parameters:

requests - the operating systems

Returns:

a set of operating systems

Throws:

AmbariException - if the resources cannot be read

getAuthName

public String getAuthName()

Description copied from interface: AmbariManagementController

Get the authenticated user's name.

Specified by:

getAuthName in interface AmbariManagementController

Returns:

the authenticated user's name

getRootServices

public Set<RootServiceResponse> getRootServices(Set<RootServiceRequest> requests)
                                         throws AmbariException

Description copied from interface: AmbariManagementController

Get all top-level services of Ambari, not related to certain cluster.

Specified by:

getRootServices in interface AmbariManagementController

Parameters:

requests - the top-level services

Returns:

a set of top-level services

Throws:

AmbariException - if the resources cannot be read

getRootServiceComponents

public Set<RootServiceComponentResponse> getRootServiceComponents(Set<RootServiceComponentRequest> requests)
                                                           throws AmbariException

Description copied from interface: AmbariManagementController

Get all components of top-level services of Ambari, not related to certain cluster.

Specified by:

getRootServiceComponents in interface AmbariManagementController

Parameters:

requests - the components of top-level services

Returns:

a set of components

Throws:

AmbariException - if the resources cannot be read

getClusters

public Clusters getClusters()

Description copied from interface: AmbariManagementController

Get the clusters for this management controller.

Specified by:

getClusters in interface AmbariManagementController

Returns:

the clusters

getAmbariMetaInfo

public AmbariMetaInfo getAmbariMetaInfo()

Description copied from interface: AmbariManagementController

Get the meta info for this management controller.

Specified by:

getAmbariMetaInfo in interface AmbariManagementController

Returns:

the meta info

getServiceFactory

public ServiceFactory getServiceFactory()

Description copied from interface: AmbariManagementController

Get the service factory for this management controller.

Specified by:

getServiceFactory in interface AmbariManagementController

Returns:

the service factory

getServiceComponentFactory

public ServiceComponentFactory getServiceComponentFactory()

Description copied from interface: AmbariManagementController

Get the service component factory for this management controller.

Specified by:

getServiceComponentFactory in interface AmbariManagementController

Returns:

the service component factory

getConfigGroupFactory

public ConfigGroupFactory getConfigGroupFactory()

Description copied from interface: AmbariManagementController

Get the config group factory for this management controller.

Specified by:

getConfigGroupFactory in interface AmbariManagementController

Returns:

the config group factory

getRootServiceResponseFactory

public AbstractRootServiceResponseFactory getRootServiceResponseFactory()

Description copied from interface: AmbariManagementController

Get the root service response factory for this management controller.

Specified by:

getRootServiceResponseFactory in interface AmbariManagementController

Returns:

the root service response factory

getActionManager

public ActionManager getActionManager()

Description copied from interface: AmbariManagementController

Get the action manager for this management controller.

Specified by:

getActionManager in interface AmbariManagementController

Returns:

the action manager

getJdkResourceUrl

public String getJdkResourceUrl()

Description copied from interface: AmbariManagementController

Getter for the url of JDK, stored at server resources folder

Specified by:

getJdkResourceUrl in interface AmbariManagementController

getJavaHome

public String getJavaHome()

Description copied from interface: AmbariManagementController

Getter for the java home, stored in ambari.properties

Specified by:

getJavaHome in interface AmbariManagementController

getJDKName

public String getJDKName()

Description copied from interface: AmbariManagementController

Getter for the jdk name, stored in ambari.properties

Specified by:

getJDKName in interface AmbariManagementController

getJCEName

public String getJCEName()

Description copied from interface: AmbariManagementController

Getter for the jce name, stored in ambari.properties

Specified by:

getJCEName in interface AmbariManagementController

getServerDB

public String getServerDB()

Description copied from interface: AmbariManagementController

Getter for the name of server database

Specified by:

getServerDB in interface AmbariManagementController

getOjdbcUrl

public String getOjdbcUrl()

Description copied from interface: AmbariManagementController

Getter for the url of Oracle JDBC driver, stored at server resources folder

Specified by:

getOjdbcUrl in interface AmbariManagementController

getMysqljdbcUrl

public String getMysqljdbcUrl()

Description copied from interface: AmbariManagementController

Getter for the url of MySQL JDBC driver, stored at server resources folder

Specified by:

getMysqljdbcUrl in interface AmbariManagementController

getRcaParameters

public Map<String,String> getRcaParameters()

Description copied from interface: AmbariManagementController

Returns parameters for RCA database

Specified by:

getRcaParameters in interface AmbariManagementController

Returns:

the map with parameters for RCA db