public class AmbariManagementControllerImpl extends Object implements AmbariManagementController
| Modifier and Type | Field and Description |
|---|---|
static Pattern |
CLUSTER_NAME_PTRN |
static String |
CLUSTER_NAME_VALIDATION_REGEXP |
static String |
CLUSTER_PHASE_INITIAL_INSTALL |
static String |
CLUSTER_PHASE_INITIAL_START |
static String |
CLUSTER_PHASE_PROPERTY |
protected OsFamily |
osFamily |
| Constructor and Description |
|---|
AmbariManagementControllerImpl(ActionManager actionManager,
Clusters clusters,
com.google.inject.Injector injector) |
| 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,
boolean useGeneratedConfigs)
Add stages to the request.
|
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,
boolean useGeneratedConfigs,
boolean useClusterHostInfo)
Add stages to the request.
|
boolean |
checkLdapConfigured()
Performs a test if LDAP server is reachable.
|
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.
|
Config |
createConfig(Cluster cluster,
StackId stackId,
String type,
Map<String,String> properties,
String versionTag,
Map<String,Map<String,String>> propertiesAttributes)
Create cluster config
TODO move this method to Cluster? doesn't seem to be on its place
|
ConfigurationResponse |
createConfiguration(ConfigurationRequest request)
Creates a configuration.
|
void |
createExtensionLink(ExtensionLinkRequest request)
This method will create a link between an extension version and a stack version (Extension Link).
|
void |
createGroups(Set<GroupRequest> requests)
Creates groups.
|
void |
createHostComponents(Set<ServiceComponentHostRequest> requests)
Create the host component defined by the attributes in the given request object.
|
void |
createHostComponents(Set<ServiceComponentHostRequest> requests,
boolean isBlueprintProvisioned)
Create the host component defined by the attributes in the given request object.
|
void |
createMembers(Set<MemberRequest> requests)
Creates members of the group.
|
Set<ServiceConfigVersionResponse> |
createServiceConfigVersion(Set<ServiceConfigVersionRequest> requests)
Creates serviceconfigversions and corresponding new configurations if it is an initial request
OR
Rollbacks to an existing serviceconfigversion if request specifies.
|
void |
deleteCluster(ClusterRequest request)
Delete the cluster identified by the given request object.
|
void |
deleteExtensionLink(ExtensionLinkRequest request)
This method will delete a link between an extension version and a stack version (Extension Link).
|
void |
deleteGroups(Set<GroupRequest> requests)
Deletes the user groups specified.
|
DeleteStatusMetaData |
deleteHostComponents(Set<ServiceComponentHostRequest> requests)
Delete the host component identified by the given request object.
|
void |
deleteMembers(Set<MemberRequest> requests)
Deletes the group members specified.
|
protected RequestStageContainer |
doStageCreation(RequestStageContainer requestStages,
Cluster cluster,
Map<State,List<Service>> changedServices,
Map<State,List<ServiceComponent>> changedComps,
Map<String,Map<State,List<ServiceComponentHost>>> changedScHosts,
Map<String,String> requestParameters,
Map<String,String> requestProperties,
boolean runSmokeTest,
boolean reconfigureClients,
boolean useLatestConfigs,
boolean useClusterHostInfo) |
protected void |
filterHostsForAction(Set<String> candidateHosts,
Service service,
Cluster cluster,
Resource.Type level)
Utility method that filters out hosts from set based on their maintenance
state status.
|
Map<String,Map<String,String>> |
findConfigurationTagsWithOverrides(Cluster cluster,
String hostName)
Find configuration tags with applied overrides
|
String |
findServiceName(Cluster cluster,
String componentName)
Get service name by cluster instance and component name
|
ActionManager |
getActionManager()
Get the action manager for this management controller.
|
TopologyUpdateEvent |
getAddedComponentsTopologyEvent(Set<ServiceComponentHostRequest> requests) |
AmbariEventPublisher |
getAmbariEventPublisher()
Gets an
AmbariEventPublisher which can be used to send and receive
AmbariEvents. |
AmbariMetaInfo |
getAmbariMetaInfo()
Get the meta info for this management controller.
|
String |
getAmbariServerURI(String path)
Get an Ambari endpoint URI for the given path.
|
int |
getAuthId()
Get the authenticated user's id.
|
String |
getAuthName()
Get the authenticated user's name.
|
Map<String,BlueprintProvisioningState> |
getBlueprintProvisioningStates(Long clusterId,
Long hostId) |
protected ServiceComponent |
getClientComponentForRunningAction(Cluster cluster,
Service service) |
protected String |
getClientHostForRunningAction(Cluster cluster,
Service service,
ServiceComponent serviceComponent) |
MetadataUpdateEvent |
getClusterMetadata(Cluster cl) |
MetadataUpdateEvent |
getClusterMetadataOnConfigsUpdate(Cluster cl) |
MetadataUpdateEvent |
getClusterMetadataOnRepoUpdate(Cluster cl) |
MetadataUpdateEvent |
getClusterMetadataOnServiceCredentialStoreUpdate(Cluster cl,
String serviceName) |
MetadataUpdateEvent |
getClusterMetadataOnServiceInstall(Cluster cl,
String serviceName) |
Clusters |
getClusters()
Get the clusters for this management controller.
|
Set<ClusterResponse> |
getClusters(Set<ClusterRequest> requests)
Get the clusters identified by the given request objects.
|
MetadataUpdateEvent |
getClustersMetadata()
Collects full metadata info about clusters for agent.
|
ClusterResponse |
getClusterUpdateResults(ClusterRequest clusterRequest)
Get cached clusterUpdateResults, used only for service config versions currently
|
ConfigGroupFactory |
getConfigGroupFactory()
Get the config group factory for this management controller.
|
ConfigGroupResponse |
getConfigGroupUpdateResults(ConfigGroupRequest configGroupRequest) |
ConfigHelper |
getConfigHelper()
Get config helper
|
Set<ConfigurationResponse> |
getConfigurations(Set<ConfigurationRequest> requests)
Gets the configurations identified by the given request objects.
|
CredentialStoreService |
getCredentialStoreService()
Returns the CredentialStoreService implementation associated with this
controller
|
Map<String,String> |
getCredentialStoreServiceProperties()
Queries the CredentialStoreService to gather properties about it.
|
MaintenanceState |
getEffectiveMaintenanceState(ServiceComponentHost sch)
Gets the effective maintenance state for a host component
|
ExecutionCommand |
getExecutionCommand(Cluster cluster,
ServiceComponentHost scHost,
RoleCommand roleCommand)
Gets an execution command for host component life cycle command
|
ExecutionScheduleManager |
getExecutionScheduleManager()
Get Execution Schedule Manager
|
Set<ExtensionResponse> |
getExtensions(Set<ExtensionRequest> requests)
Get supported extensions.
|
Set<ExtensionVersionResponse> |
getExtensionVersions(Set<ExtensionVersionRequest> requests)
Get supported extension versions.
|
Set<GroupResponse> |
getGroups(Set<GroupRequest> requests)
Gets the user groups identified by the given request objects.
|
String |
getHealthyHost(Set<String> hostList)
Chooses a healthy host from the list of candidate hosts randomly.
|
Set<ServiceComponentHostResponse> |
getHostComponents(Set<ServiceComponentHostRequest> requests)
Get the host components identified by the given request objects.
|
Set<ServiceComponentHostResponse> |
getHostComponents(Set<ServiceComponentHostRequest> requests,
boolean statusOnly) |
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
HDP-1.x is not supported anymore
|
KerberosHelper |
getKerberosHelper()
Returns KerberosHelper instance
|
LdapSyncDto |
getLdapSyncInfo()
Retrieves groups and users from external LDAP.
|
LoggingSearchPropertyProvider |
getLoggingSearchPropertyProvider()
Gets the LoggingSearchPropertyProvider instance.
|
LoggingService |
getLoggingService(String clusterName)
Gets the LoggingService instance from the dependency injection framework.
|
Set<MemberResponse> |
getMembers(Set<MemberRequest> requests)
Gets the group members identified by the given request objects.
|
SortedMap<String,SortedMap<String,String>> |
getMetadataAgentConfigs() |
TreeMap<String,String> |
getMetadataAmbariLevelParams() |
TreeMap<String,String> |
getMetadataClusterLevelParams(Cluster cluster,
StackId stackId) |
TreeMap<String,MetadataServiceInfo> |
getMetadataServiceLevelParams(Cluster cluster) |
TreeMap<String,MetadataServiceInfo> |
getMetadataServiceLevelParams(Service service) |
MetricPropertyProviderFactory |
getMetricPropertyProviderFactory()
Gets the
MetricPropertyProviderFactory that was injected into this
class. |
MetricsCollectorHAManager |
getMetricsCollectorHAManager()
Gets an
MetricsCollectorHAManager which can be used to get/add collector host for a cluster |
List<Module> |
getModules(Long mpackId)
Fetch the module info for a given mpack.
|
MpackResponse |
getMpack(Long mpackId)
Fetch an mpack based on id
|
Set<MpackResponse> |
getMpacks()
Fetch all mpacks
|
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
|
Set<OperatingSystemResponse> |
getOperatingSystems(Set<OperatingSystemRequest> requests)
Get operating systems by stack name, version.
|
List<ServiceOsSpecific.Package> |
getPackagesForServiceHost(ServiceInfo serviceInfo,
Map<String,String> hostParams,
String osFamily) |
QuickLinkVisibilityController |
getQuicklinkVisibilityController() |
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
|
RoleCommandOrder |
getRoleCommandOrder(Cluster cluster)
Get Role Command Order
|
RoleGraphFactory |
getRoleGraphFactory()
Get the role graph factory for this management controller.
|
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.
|
Set<ServiceConfigVersionResponse> |
getServiceConfigVersions(Set<ServiceConfigVersionRequest> requests)
Get service config version history
|
Set<StackServiceComponentResponse> |
getStackComponents(Set<StackServiceComponentRequest> requests)
Get components by stack name, version and service.
|
Set<StackConfigurationDependencyResponse> |
getStackConfigurationDependencies(Set<StackConfigurationDependencyRequest> requests)
Get configuration dependencies which are specific for a specific service configuration property
|
Set<StackConfigurationResponse> |
getStackConfigurations(Set<StackConfigurationRequest> requests)
Get configurations by stack name, version and service.
|
Set<StackConfigurationResponse> |
getStackLevelConfigurations(Set<StackLevelConfigurationRequest> requests)
Get configurations which are specific for a cluster (!not a service).
|
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.
|
TimelineMetricCacheProvider |
getTimelineMetricCacheProvider() |
TreeMap<String,String> |
getTopologyCommandParams(Long clusterId,
String serviceName,
String componentName,
ServiceComponentHost sch) |
TreeMap<String,String> |
getTopologyComponentLevelParams(Long clusterId,
String serviceName,
String componentName,
SecurityType clusterSecurityType) |
void |
initializeWidgetsAndLayouts(Cluster cluster,
Service service)
Initialize cluster scoped widgets and widgetLayouts for different stack
components.
|
boolean |
isAttributeMapsEqual(Map<String,Map<String,String>> requestConfigAttributes,
Map<String,Map<String,String>> clusterConfigAttributes)
Comparison of two attributes maps
|
boolean |
isLdapSyncInProgress()
Checks if LDAP sync process is running.
|
protected ServiceOsSpecific |
populateServicePackagesInfo(ServiceInfo serviceInfo,
Map<String,String> hostParams,
String osFamily)
Computes os-dependent packages for service/host.
|
MpackResponse |
registerMpack(MpackRequest request)
Register the mpack defined by the attributes in the given request object.
|
void |
registerRackChange(String clusterName)
Register a change in rack information for the hosts of the given cluster.
|
void |
removeMpack(MpackEntity mpackEntity,
StackEntity stackEntity)
Remove Mpack from the mpackMap and stackMap which is used to power the Mpack and Stack APIs.
|
void |
saveClusterUpdate(ClusterRequest clusterRequest,
ClusterResponse clusterResponse)
Save cluster update results to retrieve later
|
void |
saveConfigGroupUpdate(ConfigGroupRequest configGroupRequest,
ConfigGroupResponse configGroupResponse) |
List<String> |
selectHealthyHosts(Set<String> hostList)
Filters hosts to only select healthy ones that are heartbeating.
|
LdapBatchDto |
synchronizeLdapUsersAndGroups(LdapSyncRequest userRequest,
LdapSyncRequest groupRequest)
Synchronizes local users and groups with given data.
|
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 |
updateClusters(Set<ClusterRequest> requests,
Map<String,String> requestProperties,
boolean fireAgentUpdates)
Update the cluster identified by the given request object with the
values carried by the given request object.
|
void |
updateExtensionLink(ExtensionLinkEntity oldLinkEntity,
ExtensionLinkRequest newLinkRequest)
Update a link - switch the link's extension version while keeping the same stack version and extension name
|
void |
updateExtensionLink(ExtensionLinkRequest request)
Update a link - switch the link's extension version while keeping the same stack version and extension name
|
void |
updateGroups(Set<GroupRequest> requests)
Updates the groups specified.
|
void |
updateMembers(Set<MemberRequest> requests)
Updates the members of the group specified.
|
RequestStatusResponse |
updateStacks()
Update stacks from the files at stackRoot.
|
protected void |
validateAuthorizationToManageServiceAutoStartConfiguration(Cluster cluster,
String configType,
Map<String,String[]> propertyChanges)
Validates that the authenticated user can manage the cluster-wide configuration for a service's
ability to be set to auto-start.
|
protected void |
validateAuthorizationToUpdateServiceUsersAndGroups(Cluster cluster,
String configType,
Map<String,String[]> propertyChanges)
Validates that the authenticated user can set a service's (run-as) user and group.
|
static void |
validateClusterName(String clusterName)
validate cluster name character and length requirements and throw IllegalArgumentException if not valid.
|
void |
validateServiceComponentHostRequest(ServiceComponentHostRequest request) |
void |
verifyRepositories(Set<RepositoryRequest> requests)
Verifies repositories' base urls.
|
public static final String CLUSTER_PHASE_PROPERTY
public static final String CLUSTER_PHASE_INITIAL_INSTALL
public static final String CLUSTER_PHASE_INITIAL_START
public static final String CLUSTER_NAME_VALIDATION_REGEXP
public static final Pattern CLUSTER_NAME_PTRN
@Inject protected OsFamily osFamily
@Inject public AmbariManagementControllerImpl(ActionManager actionManager, Clusters clusters, com.google.inject.Injector injector) throws Exception
Exceptionpublic String getAmbariServerURI(String path)
AmbariManagementControllergetAmbariServerURI in interface AmbariManagementControllerpath - the path (e.g. /api/v1/users)public RoleCommandOrder getRoleCommandOrder(Cluster cluster)
AmbariManagementControllergetRoleCommandOrder in interface AmbariManagementControllerpublic void createCluster(ClusterRequest request) throws org.apache.ambari.server.AmbariException
AmbariManagementControllercreateCluster in interface AmbariManagementControllerrequest - the request object which defines the cluster to be createdorg.apache.ambari.server.AmbariException - thrown if the cluster cannot be createdpublic void createHostComponents(Set<ServiceComponentHostRequest> requests) throws org.apache.ambari.server.AmbariException, AuthorizationException
AmbariManagementControllercreateHostComponents in interface AmbariManagementControllerrequests - the request object which defines the host component to be createdorg.apache.ambari.server.AmbariException - thrown if the host component cannot be createdAuthorizationExceptionpublic MpackResponse registerMpack(MpackRequest request) throws IOException, AuthorizationException, ResourceAlreadyExistsException
registerMpack in interface AmbariManagementControllerrequest - the request object which defines the mpack to be createdorg.apache.ambari.server.AmbariException - thrown if the mpack cannot be createdAuthorizationException - thrown if the authenticated user is not authorized to perform this operationIOExceptionResourceAlreadyExistsExceptionpublic Set<MpackResponse> getMpacks()
AmbariManagementControllergetMpacks in interface AmbariManagementControllerpublic MpackResponse getMpack(Long mpackId)
AmbariManagementControllergetMpack in interface AmbariManagementControllerpublic List<Module> getModules(Long mpackId)
AmbariManagementControllergetModules in interface AmbariManagementControllerpublic void createHostComponents(Set<ServiceComponentHostRequest> requests, boolean isBlueprintProvisioned) throws org.apache.ambari.server.AmbariException, AuthorizationException
AmbariManagementControllercreateHostComponents in interface AmbariManagementControllerrequests - the request object which defines the host component to be createdisBlueprintProvisioned - means host components will be created during blueprint deployorg.apache.ambari.server.AmbariException - thrown if the host component cannot be createdAuthorizationExceptionpublic TopologyUpdateEvent getAddedComponentsTopologyEvent(Set<ServiceComponentHostRequest> requests) throws org.apache.ambari.server.AmbariException
getAddedComponentsTopologyEvent in interface AmbariManagementControllerorg.apache.ambari.server.AmbariExceptionpublic void registerRackChange(String clusterName) throws org.apache.ambari.server.AmbariException
AmbariManagementControllerregisterRackChange in interface AmbariManagementControllerclusterName - the name of the clusterorg.apache.ambari.server.AmbariException - if an error occurs during the rack change registrationpublic ConfigurationResponse createConfiguration(ConfigurationRequest request) throws org.apache.ambari.server.AmbariException, AuthorizationException
This implementation ensures the authenticated user is authorized to create the new configuration based on the details of what properties are being changed and the authorizations the authenticated user has been granted.
Example
SERVICE_MODIFY_CONFIGS privilege (authorization)
cluster-env/recovery_enabled), that user must be granted the
CLUSTER_MANAGE_AUTO_START privilege (authorization)
createConfiguration in interface AmbariManagementControllerrequest - the request object which defines the configuration.org.apache.ambari.server.AmbariException - when the configuration cannot be created.AuthorizationExceptionpublic Config createConfig(Cluster cluster, StackId stackId, String type, Map<String,String> properties, String versionTag, Map<String,Map<String,String>> propertiesAttributes)
AmbariManagementControllercreateConfig in interface AmbariManagementControllerpublic void createGroups(Set<GroupRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllercreateGroups in interface AmbariManagementControllerrequests - the request objects which define the groups.org.apache.ambari.server.AmbariException - when the groups cannot be created.public void createMembers(Set<MemberRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllercreateMembers in interface AmbariManagementControllerrequests - the request objects which define the members.org.apache.ambari.server.AmbariException - when the members cannot be created.public Set<MemberResponse> getMembers(Set<MemberRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllergetMembers in interface AmbariManagementControllerrequests - the request objectsorg.apache.ambari.server.AmbariException - if the members could not be readpublic void updateMembers(Set<MemberRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllerupdateMembers in interface AmbariManagementControllerrequests - the members to be set for this grouporg.apache.ambari.server.AmbariException - if the resources cannot be updatedpublic MaintenanceState getEffectiveMaintenanceState(ServiceComponentHost sch) throws org.apache.ambari.server.AmbariException
AmbariManagementControllergetEffectiveMaintenanceState in interface AmbariManagementControllersch - the service component hostorg.apache.ambari.server.AmbariExceptionpublic RequestStatusResponse updateClusters(Set<ClusterRequest> requests, Map<String,String> requestProperties) throws org.apache.ambari.server.AmbariException, AuthorizationException
AmbariManagementControllerupdateClusters in interface AmbariManagementControllerrequests - request objects which define which cluster to
update and the values to setrequestProperties - request specific properties independent of resourceorg.apache.ambari.server.AmbariException - thrown if the resource cannot be updatedAuthorizationException - thrown if the authenticated user is not authorized to perform this operationpublic RequestStatusResponse updateClusters(Set<ClusterRequest> requests, Map<String,String> requestProperties, boolean fireAgentUpdates) throws org.apache.ambari.server.AmbariException, AuthorizationException
AmbariManagementControllerupdateClusters in interface AmbariManagementControllerrequests - request objects which define which cluster to
update and the values to setrequestProperties - request specific properties independent of resourcefireAgentUpdates - should agent updates (configurations, metadata etc.) be fired insideorg.apache.ambari.server.AmbariException - thrown if the resource cannot be updatedAuthorizationException - thrown if the authenticated user is not authorized to perform this operationpublic static void validateClusterName(String clusterName)
Character Requirements
A through Z a through z 0 through 9 _ (underscore) - (dash) Length Requirements
Minimum: 1 character Maximum: 100 characters
clusterName - name to validateIllegalArgumentException - if validation resultCLUSTER_NAME_VALIDATION_REGEXPpublic boolean isAttributeMapsEqual(Map<String,Map<String,String>> requestConfigAttributes, Map<String,Map<String,String>> clusterConfigAttributes)
requestConfigAttributes - - attribute map sent from APIclusterConfigAttributes - - existed attribute mappublic void saveClusterUpdate(ClusterRequest clusterRequest, ClusterResponse clusterResponse)
clusterRequest - cluster request infoclusterResponse - cluster response infopublic ClusterResponse getClusterUpdateResults(ClusterRequest clusterRequest)
AmbariManagementControllergetClusterUpdateResults in interface AmbariManagementControllerpublic ConfigGroupResponse getConfigGroupUpdateResults(ConfigGroupRequest configGroupRequest)
getConfigGroupUpdateResults in interface AmbariManagementControllerpublic void saveConfigGroupUpdate(ConfigGroupRequest configGroupRequest, ConfigGroupResponse configGroupResponse)
saveConfigGroupUpdate in interface AmbariManagementControllerpublic String getJobTrackerHost(Cluster cluster)
AmbariManagementControllergetJobTrackerHost in interface AmbariManagementControllerpublic Map<String,Map<String,String>> findConfigurationTagsWithOverrides(Cluster cluster, String hostName) throws org.apache.ambari.server.AmbariException
AmbariManagementControllerfindConfigurationTagsWithOverrides in interface AmbariManagementControllercluster - the clusterhostName - the host nameorg.apache.ambari.server.AmbariException - if configuration tags can not be obtainedpublic RequestExecutionFactory getRequestExecutionFactory()
AmbariManagementControllergetRequestExecutionFactory in interface AmbariManagementControllerpublic ExecutionScheduleManager getExecutionScheduleManager()
AmbariManagementControllergetExecutionScheduleManager in interface AmbariManagementControllerprotected ServiceOsSpecific populateServicePackagesInfo(ServiceInfo serviceInfo, Map<String,String> hostParams, String osFamily)
hostParams - may be modified (appended SERVICE_REPO_INFO)public List<ServiceOsSpecific.Package> getPackagesForServiceHost(ServiceInfo serviceInfo, Map<String,String> hostParams, String osFamily)
getPackagesForServiceHost in interface AmbariManagementControllerserviceInfo - service info for a given servicehostParams - parameter map. May be changed during method executionosFamily - os family for hostprotected RequestStageContainer doStageCreation(RequestStageContainer requestStages, Cluster cluster, Map<State,List<Service>> changedServices, Map<State,List<ServiceComponent>> changedComps, Map<String,Map<State,List<ServiceComponentHost>>> changedScHosts, Map<String,String> requestParameters, Map<String,String> requestProperties, boolean runSmokeTest, boolean reconfigureClients, boolean useLatestConfigs, boolean useClusterHostInfo) throws org.apache.ambari.server.AmbariException
org.apache.ambari.server.AmbariExceptionpublic ExecutionCommand getExecutionCommand(Cluster cluster, ServiceComponentHost scHost, RoleCommand roleCommand) throws org.apache.ambari.server.AmbariException
AmbariManagementControllergetExecutionCommand in interface AmbariManagementControllerorg.apache.ambari.server.AmbariExceptionpublic Set<StackConfigurationDependencyResponse> getStackConfigurationDependencies(Set<StackConfigurationDependencyRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllergetStackConfigurationDependencies in interface AmbariManagementControllerorg.apache.ambari.server.AmbariExceptionpublic 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 org.apache.ambari.server.AmbariException
AmbariManagementControllercreateAndPersistStages in interface AmbariManagementControllercluster - 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 reconfiguredorg.apache.ambari.server.AmbariException - is thrown if the stages can not be createdpublic 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, boolean useGeneratedConfigs) throws org.apache.ambari.server.AmbariException
AmbariManagementControlleraddStages in interface AmbariManagementControllerrequestStages - 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 reconfiguredorg.apache.ambari.server.AmbariException - if stages can't be createdpublic 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, boolean useGeneratedConfigs, boolean useClusterHostInfo) throws org.apache.ambari.server.AmbariException
AmbariManagementControlleraddStages in interface AmbariManagementControllerrequestStages - 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 reconfigureduseGeneratedConfigs - indicates whether or not the actual configs should be a part of the stageuseClusterHostInfo - indicates whether or not the cluster topology info should be a part of the stageorg.apache.ambari.server.AmbariException - if stages can't be createdpublic void validateServiceComponentHostRequest(ServiceComponentHostRequest request)
public String findServiceName(Cluster cluster, String componentName) throws org.apache.ambari.server.AmbariException
AmbariManagementControllerfindServiceName in interface AmbariManagementControllercluster - the cluster instancecomponentName - the component name in String typeorg.apache.ambari.server.AmbariException - if service name is null or emptypublic void deleteCluster(ClusterRequest request) throws org.apache.ambari.server.AmbariException
AmbariManagementControllerdeleteCluster in interface AmbariManagementControllerrequest - the request object which identifies which cluster to deleteorg.apache.ambari.server.AmbariException - thrown if the resource cannot be deletedpublic DeleteStatusMetaData deleteHostComponents(Set<ServiceComponentHostRequest> requests) throws org.apache.ambari.server.AmbariException, AuthorizationException
AmbariManagementControllerdeleteHostComponents in interface AmbariManagementControllerrequests - the request object which identifies which host component to deleteorg.apache.ambari.server.AmbariException - thrown if the resource cannot be deletedAuthorizationExceptionpublic void deleteGroups(Set<GroupRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllerdeleteGroups in interface AmbariManagementControllerrequests - the groups to deleteorg.apache.ambari.server.AmbariException - if the resources cannot be deletedpublic void deleteMembers(Set<MemberRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllerdeleteMembers in interface AmbariManagementControllerrequests - the members to deleteorg.apache.ambari.server.AmbariException - if the resources cannot be deletedpublic void removeMpack(MpackEntity mpackEntity, StackEntity stackEntity) throws IOException
removeMpack in interface AmbariManagementControllerIOExceptionpublic Set<ServiceConfigVersionResponse> createServiceConfigVersion(Set<ServiceConfigVersionRequest> requests) throws org.apache.ambari.server.AmbariException, AuthorizationException
AmbariManagementControllercreateServiceConfigVersion in interface AmbariManagementControllerorg.apache.ambari.server.AmbariExceptionAuthorizationExceptionpublic Set<ClusterResponse> getClusters(Set<ClusterRequest> requests) throws org.apache.ambari.server.AmbariException, AuthorizationException
AmbariManagementControllergetClusters in interface AmbariManagementControllerrequests - the request objects which identify the clusters to be returnedorg.apache.ambari.server.AmbariException - thrown if the resource cannot be readAuthorizationException - thrown if the authenticated user is not authorized to perform this operationpublic Set<ServiceComponentHostResponse> getHostComponents(Set<ServiceComponentHostRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllergetHostComponents in interface AmbariManagementControllerrequests - the request objects which identify the host components
to be returnedorg.apache.ambari.server.AmbariException - thrown if the resource cannot be readpublic Set<ServiceComponentHostResponse> getHostComponents(Set<ServiceComponentHostRequest> requests, boolean statusOnly) throws org.apache.ambari.server.AmbariException
getHostComponents in interface AmbariManagementControllerorg.apache.ambari.server.AmbariExceptionpublic Set<ConfigurationResponse> getConfigurations(Set<ConfigurationRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllergetConfigurations in interface AmbariManagementControllerrequests - the request objectsorg.apache.ambari.server.AmbariException - if the configurations could not be readpublic Set<ServiceConfigVersionResponse> getServiceConfigVersions(Set<ServiceConfigVersionRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllergetServiceConfigVersions in interface AmbariManagementControllerrequests - service config version requestsorg.apache.ambari.server.AmbariExceptionpublic Set<GroupResponse> getGroups(Set<GroupRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllergetGroups in interface AmbariManagementControllerrequests - the request objectsorg.apache.ambari.server.AmbariException - if the groups could not be readpublic void updateGroups(Set<GroupRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllerupdateGroups in interface AmbariManagementControllerrequests - the groups to modifyorg.apache.ambari.server.AmbariException - if the resources cannot be updatedprotected String getClientHostForRunningAction(Cluster cluster, Service service, ServiceComponent serviceComponent) throws org.apache.ambari.server.AmbariException
org.apache.ambari.server.AmbariExceptionprotected ServiceComponent getClientComponentForRunningAction(Cluster cluster, Service service) throws org.apache.ambari.server.AmbariException
org.apache.ambari.server.AmbariExceptionprotected void filterHostsForAction(Set<String> candidateHosts, Service service, Cluster cluster, Resource.Type level) throws org.apache.ambari.server.AmbariException
org.apache.ambari.server.AmbariExceptionpublic List<String> selectHealthyHosts(Set<String> hostList) throws org.apache.ambari.server.AmbariException
HostState is used to determine if a host is healthy.selectHealthyHosts in interface AmbariManagementControllerorg.apache.ambari.server.AmbariExceptionHostState#HEALTHY}public String getHealthyHost(Set<String> hostList) throws org.apache.ambari.server.AmbariException
null.
The host's HostState is used to determine if a host is healthy.getHealthyHost in interface AmbariManagementControllernull.org.apache.ambari.server.AmbariExceptionHostState#HEALTHY}public RequestStatusResponse createAction(ExecuteActionRequest actionRequest, Map<String,String> requestProperties) throws org.apache.ambari.server.AmbariException
AmbariManagementControllercreateAction in interface AmbariManagementControlleractionRequest - the request object which defines the action to be createdrequestProperties - the request propertiesorg.apache.ambari.server.AmbariException - thrown if the action cannot be createdpublic Set<StackResponse> getStacks(Set<StackRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllergetStacks in interface AmbariManagementControllerrequests - the stacksorg.apache.ambari.server.AmbariException - if the resources cannot be readpublic RequestStatusResponse updateStacks() throws org.apache.ambari.server.AmbariException
AmbariManagementControllerupdateStacks in interface AmbariManagementControllerorg.apache.ambari.server.AmbariException - ifpublic Set<ExtensionResponse> getExtensions(Set<ExtensionRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllergetExtensions in interface AmbariManagementControllerrequests - the extensionsorg.apache.ambari.server.AmbariException - if the resources cannot be readpublic Set<ExtensionVersionResponse> getExtensionVersions(Set<ExtensionVersionRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllergetExtensionVersions in interface AmbariManagementControllerrequests - the extension versionsorg.apache.ambari.server.AmbariException - if the resources cannot be readpublic Set<RepositoryResponse> getRepositories(Set<RepositoryRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllergetRepositories in interface AmbariManagementControllerrequests - the repositoriesorg.apache.ambari.server.AmbariException - if the resources cannot be readpublic void verifyRepositories(Set<RepositoryRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllerverifyRepositories in interface AmbariManagementControllerrequests - the repositoriesorg.apache.ambari.server.AmbariException - if verification of any of urls failspublic Set<StackVersionResponse> getStackVersions(Set<StackVersionRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllergetStackVersions in interface AmbariManagementControllerrequests - the stacks versionsorg.apache.ambari.server.AmbariException - if the resources cannot be readpublic Set<StackServiceResponse> getStackServices(Set<StackServiceRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllergetStackServices in interface AmbariManagementControllerrequests - the servicesorg.apache.ambari.server.AmbariException - if the resources cannot be readpublic Set<StackConfigurationResponse> getStackLevelConfigurations(Set<StackLevelConfigurationRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllergetStackLevelConfigurations in interface AmbariManagementControllerorg.apache.ambari.server.AmbariExceptionpublic Set<StackConfigurationResponse> getStackConfigurations(Set<StackConfigurationRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllergetStackConfigurations in interface AmbariManagementControllerrequests - the configurationsorg.apache.ambari.server.AmbariException - if the resources cannot be readpublic Set<StackServiceComponentResponse> getStackComponents(Set<StackServiceComponentRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllergetStackComponents in interface AmbariManagementControllerrequests - the componentsorg.apache.ambari.server.AmbariException - if the resources cannot be readpublic Set<OperatingSystemResponse> getOperatingSystems(Set<OperatingSystemRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllergetOperatingSystems in interface AmbariManagementControllerrequests - the operating systemsorg.apache.ambari.server.AmbariException - if the resources cannot be readpublic String getAuthName()
AmbariManagementControllergetAuthName in interface AmbariManagementControllerpublic int getAuthId()
AmbariManagementControllergetAuthId in interface AmbariManagementControllerpublic Set<RootServiceResponse> getRootServices(Set<RootServiceRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllergetRootServices in interface AmbariManagementControllerrequests - the top-level servicesorg.apache.ambari.server.AmbariException - if the resources cannot be readpublic Set<RootServiceComponentResponse> getRootServiceComponents(Set<RootServiceComponentRequest> requests) throws org.apache.ambari.server.AmbariException
AmbariManagementControllergetRootServiceComponents in interface AmbariManagementControllerrequests - the components of top-level servicesorg.apache.ambari.server.AmbariException - if the resources cannot be readpublic Clusters getClusters()
AmbariManagementControllergetClusters in interface AmbariManagementControllerpublic ConfigHelper getConfigHelper()
AmbariManagementControllergetConfigHelper in interface AmbariManagementControllerpublic AmbariMetaInfo getAmbariMetaInfo()
AmbariManagementControllergetAmbariMetaInfo in interface AmbariManagementControllerpublic ServiceComponentFactory getServiceComponentFactory()
AmbariManagementControllergetServiceComponentFactory in interface AmbariManagementControllerpublic ConfigGroupFactory getConfigGroupFactory()
AmbariManagementControllergetConfigGroupFactory in interface AmbariManagementControllerpublic RoleGraphFactory getRoleGraphFactory()
AmbariManagementControllergetRoleGraphFactory in interface AmbariManagementControllerpublic AbstractRootServiceResponseFactory getRootServiceResponseFactory()
AmbariManagementControllergetRootServiceResponseFactory in interface AmbariManagementControllerpublic ActionManager getActionManager()
AmbariManagementControllergetActionManager in interface AmbariManagementControllerpublic String getJdkResourceUrl()
AmbariManagementControllergetJdkResourceUrl in interface AmbariManagementControllerpublic String getJavaHome()
AmbariManagementControllergetJavaHome in interface AmbariManagementControllerpublic String getJDKName()
AmbariManagementControllergetJDKName in interface AmbariManagementControllerpublic String getJCEName()
AmbariManagementControllergetJCEName in interface AmbariManagementControllerpublic String getServerDB()
AmbariManagementControllergetServerDB in interface AmbariManagementControllerpublic String getOjdbcUrl()
AmbariManagementControllergetOjdbcUrl in interface AmbariManagementControllerpublic String getMysqljdbcUrl()
AmbariManagementControllergetMysqljdbcUrl in interface AmbariManagementControllerpublic Map<String,String> getRcaParameters()
AmbariManagementControllergetRcaParameters in interface AmbariManagementControllerpublic boolean checkLdapConfigured()
AmbariManagementControllercheckLdapConfigured in interface AmbariManagementControllerpublic LdapSyncDto getLdapSyncInfo() throws org.apache.ambari.server.AmbariException
AmbariManagementControllergetLdapSyncInfo in interface AmbariManagementControllerorg.apache.ambari.server.AmbariException - if LDAP is configured incorrectlypublic boolean isLdapSyncInProgress()
AmbariManagementControllerisLdapSyncInProgress in interface AmbariManagementControllerpublic LdapBatchDto synchronizeLdapUsersAndGroups(LdapSyncRequest userRequest, LdapSyncRequest groupRequest) throws org.apache.ambari.server.AmbariException
AmbariManagementControllersynchronizeLdapUsersAndGroups in interface AmbariManagementControlleruserRequest - users to be synchronizedgroupRequest - groups to be synchronizedorg.apache.ambari.server.AmbariException - if synchronization data was invalidpublic void initializeWidgetsAndLayouts(Cluster cluster, Service service) throws org.apache.ambari.server.AmbariException
AmbariManagementControllerinitializeWidgetsAndLayouts in interface AmbariManagementControllercluster - @Cluster objectservice - @Service objectorg.apache.ambari.server.AmbariExceptionpublic TimelineMetricCacheProvider getTimelineMetricCacheProvider()
getTimelineMetricCacheProvider in interface AmbariManagementControllerpublic MetricPropertyProviderFactory getMetricPropertyProviderFactory()
MetricPropertyProviderFactory that was injected into this
class. This is a terrible pattern.getMetricPropertyProviderFactory in interface AmbariManagementControllerMetricPropertyProviderFactorypublic LoggingSearchPropertyProvider getLoggingSearchPropertyProvider()
AmbariManagementControllergetLoggingSearchPropertyProvider in interface AmbariManagementControllerLoggingSearchPropertyProviderpublic LoggingService getLoggingService(String clusterName)
AmbariManagementControllergetLoggingService in interface AmbariManagementControllerclusterName - the cluster name associated with this LoggingService instancepublic AmbariEventPublisher getAmbariEventPublisher()
AmbariEventPublisher which can be used to send and receive
AmbariEvents.getAmbariEventPublisher in interface AmbariManagementControllerpublic KerberosHelper getKerberosHelper()
AmbariManagementControllergetKerberosHelper in interface AmbariManagementControllerpublic CredentialStoreService getCredentialStoreService()
AmbariManagementControllergetCredentialStoreService in interface AmbariManagementControllerpublic Map<String,String> getCredentialStoreServiceProperties()
public MetricsCollectorHAManager getMetricsCollectorHAManager()
AmbariManagementControllerMetricsCollectorHAManager which can be used to get/add collector host for a clustergetMetricsCollectorHAManager in interface AmbariManagementControllerMetricsCollectorHAManagerprotected void validateAuthorizationToUpdateServiceUsersAndGroups(Cluster cluster, String configType, Map<String,String[]> propertyChanges) throws AuthorizationException
cluster - the relevant clusterconfigType - the changed configuration typepropertyChanges - a map of the property changes for the relevant configuration typeAuthorizationException - if the user is not authorized to perform this operationprotected void validateAuthorizationToManageServiceAutoStartConfiguration(Cluster cluster, String configType, Map<String,String[]> propertyChanges) throws AuthorizationException
cluster-env/recovery_enabled is not changed. If it was, an
AuthorizationException is thrown.cluster - the relevant clusterconfigType - the changed configuration typepropertyChanges - a map of the property changes for the relevant configuration typeAuthorizationException - if the user is not authorized to perform this operationpublic void deleteExtensionLink(ExtensionLinkRequest request) throws org.apache.ambari.server.AmbariException
deleteExtensionLink in interface AmbariManagementControllerorg.apache.ambari.server.AmbariException - if we fail to unlink the extension from the stackpublic void createExtensionLink(ExtensionLinkRequest request) throws org.apache.ambari.server.AmbariException
createExtensionLink in interface AmbariManagementControllerorg.apache.ambari.server.AmbariException - if we fail to link the extension to the stackpublic void updateExtensionLink(ExtensionLinkRequest request) throws org.apache.ambari.server.AmbariException
updateExtensionLink in interface AmbariManagementControllerorg.apache.ambari.server.AmbariException - if we fail to link the extension to the stackpublic void updateExtensionLink(ExtensionLinkEntity oldLinkEntity, ExtensionLinkRequest newLinkRequest) throws org.apache.ambari.server.AmbariException
updateExtensionLink in interface AmbariManagementControllerorg.apache.ambari.server.AmbariException - if we fail to link the extension to the stackpublic QuickLinkVisibilityController getQuicklinkVisibilityController()
getQuicklinkVisibilityController in interface AmbariManagementControllerpublic MetadataUpdateEvent getClustersMetadata() throws org.apache.ambari.server.AmbariException
org.apache.ambari.server.AmbariExceptionpublic MetadataUpdateEvent getClusterMetadata(Cluster cl) throws org.apache.ambari.server.AmbariException
org.apache.ambari.server.AmbariExceptionpublic MetadataUpdateEvent getClusterMetadataOnConfigsUpdate(Cluster cl) throws org.apache.ambari.server.AmbariException
getClusterMetadataOnConfigsUpdate in interface AmbariManagementControllerorg.apache.ambari.server.AmbariExceptionpublic MetadataUpdateEvent getClusterMetadataOnRepoUpdate(Cluster cl) throws org.apache.ambari.server.AmbariException
org.apache.ambari.server.AmbariExceptionpublic MetadataUpdateEvent getClusterMetadataOnServiceInstall(Cluster cl, String serviceName) throws org.apache.ambari.server.AmbariException
org.apache.ambari.server.AmbariExceptionpublic MetadataUpdateEvent getClusterMetadataOnServiceCredentialStoreUpdate(Cluster cl, String serviceName) throws org.apache.ambari.server.AmbariException
org.apache.ambari.server.AmbariExceptionpublic TreeMap<String,String> getTopologyComponentLevelParams(Long clusterId, String serviceName, String componentName, SecurityType clusterSecurityType) throws org.apache.ambari.server.AmbariException
org.apache.ambari.server.AmbariExceptionpublic Map<String,BlueprintProvisioningState> getBlueprintProvisioningStates(Long clusterId, Long hostId) throws org.apache.ambari.server.AmbariException
getBlueprintProvisioningStates in interface AmbariManagementControllerorg.apache.ambari.server.AmbariExceptionpublic TreeMap<String,String> getTopologyCommandParams(Long clusterId, String serviceName, String componentName, ServiceComponentHost sch) throws org.apache.ambari.server.AmbariException
org.apache.ambari.server.AmbariExceptionpublic TreeMap<String,String> getMetadataClusterLevelParams(Cluster cluster, StackId stackId) throws org.apache.ambari.server.AmbariException
org.apache.ambari.server.AmbariExceptionpublic TreeMap<String,MetadataServiceInfo> getMetadataServiceLevelParams(Cluster cluster) throws org.apache.ambari.server.AmbariException
org.apache.ambari.server.AmbariExceptionpublic TreeMap<String,MetadataServiceInfo> getMetadataServiceLevelParams(Service service) throws org.apache.ambari.server.AmbariException
org.apache.ambari.server.AmbariExceptionCopyright © 2022 Apache Software Foundation. All rights reserved.