public interface AmbariManagementController
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 |
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.
|
void createCluster(ClusterRequest request) throws AmbariException
request
- the request object which defines the cluster to be createdAmbariException
- thrown if the cluster cannot be createdvoid createHostComponents(Set<ServiceComponentHostRequest> requests) throws AmbariException
requests
- the request object which defines the host component to be createdAmbariException
- thrown if the host component cannot be createdvoid createConfiguration(ConfigurationRequest request) throws AmbariException
request
- the request object which defines the configuration.AmbariException
- when the configuration cannot be created.void createUsers(Set<UserRequest> requests) throws AmbariException
requests
- the request objects which defines the user.AmbariException
- when the user cannot be created.Set<ClusterResponse> getClusters(Set<ClusterRequest> requests) throws AmbariException
requests
- the request objects which identify the clusters to be returnedAmbariException
- thrown if the resource cannot be readSet<ServiceComponentHostResponse> getHostComponents(Set<ServiceComponentHostRequest> requests) throws AmbariException
requests
- the request objects which identify the host components
to be returnedAmbariException
- thrown if the resource cannot be readSet<ConfigurationResponse> getConfigurations(Set<ConfigurationRequest> requests) throws AmbariException
requests
- the request objectsAmbariException
- if the configurations could not be readSet<TaskStatusResponse> getTaskStatus(Set<TaskStatusRequest> requests) throws AmbariException
requests
- the request objectsAmbariException
- if the configurations could not be readSet<UserResponse> getUsers(Set<UserRequest> requests) throws AmbariException
requests
- the request objectsAmbariException
- if the users could not be readRequestStatusResponse updateClusters(Set<ClusterRequest> requests, Map<String,String> requestProperties) throws AmbariException
requests
- request objects which define which cluster to
update and the values to setrequestProperties
- request specific properties independent of resourceAmbariException
- thrown if the resource cannot be updatedRequestStatusResponse updateHostComponents(Set<ServiceComponentHostRequest> requests, Map<String,String> requestProperties, boolean runSmokeTest) throws AmbariException
requests
- the request object which defines which host component to
update and the values to setrequestProperties
- the request propertiesrunSmokeTest
- indicates whether or not to run a smoke testAmbariException
- thrown if the resource cannot be updatedvoid updateUsers(Set<UserRequest> requests) throws AmbariException
requests
- the users to modifyAmbariException
- if the resources cannot be updatedvoid deleteCluster(ClusterRequest request) throws AmbariException
request
- the request object which identifies which cluster to deleteAmbariException
- thrown if the resource cannot be deletedRequestStatusResponse deleteHostComponents(Set<ServiceComponentHostRequest> requests) throws AmbariException
requests
- the request object which identifies which host component to deleteAmbariException
- thrown if the resource cannot be deletedvoid deleteUsers(Set<UserRequest> requests) throws AmbariException
requests
- the users to deleteAmbariException
- if the resources cannot be deletedRequestStatusResponse createAction(ExecuteActionRequest actionRequest, Map<String,String> requestProperties) throws AmbariException
actionRequest
- the request object which defines the action to be createdrequestProperties
- the request propertiesAmbariException
- thrown if the action cannot be createdSet<StackResponse> getStacks(Set<StackRequest> requests) throws AmbariException
requests
- the stacksAmbariException
- if the resources cannot be readRequestStatusResponse updateStacks() throws AmbariException
AmbariException
- ifSet<StackVersionResponse> getStackVersions(Set<StackVersionRequest> requests) throws AmbariException
requests
- the stacks versionsAmbariException
- if the resources cannot be readSet<RepositoryResponse> getRepositories(Set<RepositoryRequest> requests) throws AmbariException
requests
- the repositoriesAmbariException
- if the resources cannot be readvoid updateRespositories(Set<RepositoryRequest> requests) throws AmbariException
requests
- the repositoriesAmbariException
Set<StackServiceResponse> getStackServices(Set<StackServiceRequest> requests) throws AmbariException
requests
- the servicesAmbariException
- if the resources cannot be readSet<StackConfigurationResponse> getStackConfigurations(Set<StackConfigurationRequest> requests) throws AmbariException
requests
- the configurationsAmbariException
- if the resources cannot be readSet<StackServiceComponentResponse> getStackComponents(Set<StackServiceComponentRequest> requests) throws AmbariException
requests
- the componentsAmbariException
- if the resources cannot be readSet<OperatingSystemResponse> getStackOperatingSystems(Set<OperatingSystemRequest> requests) throws AmbariException
requests
- the operating systemsAmbariException
- if the resources cannot be readSet<RootServiceResponse> getRootServices(Set<RootServiceRequest> requests) throws AmbariException
requests
- the top-level servicesAmbariException
- if the resources cannot be readSet<RootServiceComponentResponse> getRootServiceComponents(Set<RootServiceComponentRequest> requests) throws AmbariException
requests
- the components of top-level servicesAmbariException
- if the resources cannot be readClusters getClusters()
AmbariMetaInfo getAmbariMetaInfo()
ServiceFactory getServiceFactory()
ServiceComponentFactory getServiceComponentFactory()
AbstractRootServiceResponseFactory getRootServiceResponseFactory()
ConfigGroupFactory getConfigGroupFactory()
ActionManager getActionManager()
String getAuthName()
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
cluster
- the clusterrequestProperties
- the request propertiesrequestParameters
- the request parameters; may be nullchangedServices
- the services being changed; may be nullchangedComponents
- the components being changedchangedHosts
- the hosts being changedignoredHosts
- the hosts to be ignoredrunSmokeTest
- indicates whether or not the smoke tests should be runreconfigureClients
- indicates whether or not the clients should be reconfiguredAmbariException
- is thrown if the stages can not be createdRequestStageContainer 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
requestStages
- Stages currently associated with requestcluster
- cluster being acted onrequestProperties
- the request propertiesrequestParameters
- the request parameters; may be nullchangedServices
- the services being changed; may be nullchangedComponents
- the components being changedchangedHosts
- the hosts being changedignoredHosts
- the hosts to be ignoredrunSmokeTest
- indicates whether or not the smoke tests should be runreconfigureClients
- indicates whether or not the clients should be reconfiguredAmbariException
- if stages can't be createdString getJdkResourceUrl()
String getJavaHome()
String getJDKName()
String getJCEName()
String getServerDB()
String getOjdbcUrl()
String getMysqljdbcUrl()
String getHealthyHost(Set<String> hostList) throws AmbariException
AmbariException
Map<String,Map<String,String>> findConfigurationTagsWithOverrides(Cluster cluster, String hostName) throws AmbariException
cluster
- the clusterhostName
- the host nameAmbariException
- if configuration tags can not be obtainedMap<String,String> getRcaParameters()
RequestExecutionFactory getRequestExecutionFactory()
ExecutionScheduleManager getExecutionScheduleManager()
MaintenanceState getEffectiveMaintenanceState(ServiceComponentHost sch) throws AmbariException
sch
- the service component hostAmbariException
Copyright © 2015. All rights reserved.