| Modifier and Type | Method and Description | 
|---|---|
void | 
Stage.addHostRoleExecutionCommand(Host host,
                           Role role,
                           RoleCommand command,
                           ServiceComponentHostEvent event,
                           Cluster cluster,
                           String serviceName,
                           boolean retryAllowed,
                           boolean autoSkipFailure)
A new host role command is created for execution. 
 | 
void | 
ExecutionCommandWrapper.setVersions(Cluster cluster,
           CommandRepository commandRepository)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
AlertDefinitionCommand.addConfigs(ConfigHelper configHelper,
          Cluster cluster)
Adds cluster configuration properties as required by commands sent to agent. 
 | 
void | 
ExecutionCommand.setComponentVersions(Cluster cluster)
Used to set a map of {service -> { component -> version}}. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected Alert | 
AlertRunnable.buildAlert(Cluster cluster,
          AlertDefinitionEntity myDefinition,
          AlertState alertState,
          String message)
Builds an  
Alert instance. | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
AmbariMetaInfo.reconcileAlertDefinitions(Cluster cluster,
                         boolean updateScriptPaths)
Compares the alert definitions defined on the stack with those in the
 database and merges any new or updated definitions. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
RequestStageContainer | 
AmbariManagementController.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 | 
AmbariManagementControllerImpl.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)  | 
RequestStageContainer | 
AmbariManagementController.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. 
 | 
RequestStageContainer | 
AmbariManagementControllerImpl.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)  | 
Map<String,Map<String,String>> | 
KerberosHelperImpl.applyStackAdvisorUpdates(Cluster cluster,
                        Set<String> services,
                        Map<String,Map<String,String>> existingConfigurations,
                        Map<String,Map<String,String>> kerberosConfigurations,
                        Map<String,Set<String>> propertiesToIgnore,
                        Map<String,Set<String>> propertiesToRemove,
                        boolean kerberosEnabled)  | 
Map<String,Map<String,String>> | 
KerberosHelper.applyStackAdvisorUpdates(Cluster cluster,
                        Set<String> services,
                        Map<String,Map<String,String>> existingConfigurations,
                        Map<String,Map<String,String>> kerberosConfigurations,
                        Map<String,Set<String>> propertiesToIgnore,
                        Map<String,Set<String>> propertiesToRemove,
                        boolean kerberosEnabled)
Invokes the Stack Advisor to help determine relevant configuration changes when enabling or
 disabling Kerberos. 
 | 
Map<String,Map<String,String>> | 
KerberosHelperImpl.calculateConfigurations(Cluster cluster,
                       String hostname,
                       KerberosDescriptor kerberosDescriptor,
                       boolean includePreconfigureData,
                       boolean calculateClusterHostInfo)  | 
Map<String,Map<String,String>> | 
KerberosHelper.calculateConfigurations(Cluster cluster,
                       String hostname,
                       KerberosDescriptor kerberosDescriptor,
                       boolean includePreconfigureData,
                       boolean calculateClusterHostInfo)
Calculates the map of configurations relative to the cluster and host. 
 | 
void | 
KerberosHelperImpl.configureServices(Cluster cluster,
                 Map<String,Collection<String>> serviceFilter)  | 
void | 
KerberosHelper.configureServices(Cluster cluster,
                 Map<String,Collection<String>> serviceFilter)
Updates the relevant configurations for the components specified in the service filter. 
 | 
RequestStatusResponse | 
AmbariManagementController.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. 
 | 
RequestStatusResponse | 
AmbariManagementControllerImpl.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)  | 
Config | 
AmbariManagementController.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 
 | 
Config | 
AmbariManagementControllerImpl.createConfig(Cluster cluster,
            StackId stackId,
            String type,
            Map<String,String> properties,
            String versionTag,
            Map<String,Map<String,String>> propertiesAttributes)  | 
RequestStageContainer | 
KerberosHelperImpl.createTestIdentity(Cluster cluster,
                  Map<String,String> commandParamsStage,
                  RequestStageContainer requestStageContainer)  | 
RequestStageContainer | 
KerberosHelper.createTestIdentity(Cluster cluster,
                  Map<String,String> commandParamsStage,
                  RequestStageContainer requestStageContainer)
Create a unique identity to use for testing the general Kerberos configuration. 
 | 
void | 
KerberosHelperImpl.deleteIdentities(Cluster cluster,
                List<Component> components,
                Set<String> identities)
Deletes the kerberos identities of the given component, even if the component is already deleted. 
 | 
void | 
KerberosHelper.deleteIdentities(Cluster cluster,
                List<Component> components,
                Set<String> identities)  | 
RequestStageContainer | 
KerberosHelperImpl.deleteIdentities(Cluster cluster,
                Map<String,? extends Collection<String>> serviceComponentFilter,
                Set<String> hostFilter,
                Collection<String> identityFilter,
                RequestStageContainer requestStageContainer,
                Boolean manageIdentities)  | 
RequestStageContainer | 
KerberosHelper.deleteIdentities(Cluster cluster,
                Map<String,? extends Collection<String>> serviceComponentFilter,
                Set<String> hostFilter,
                Collection<String> identityFilter,
                RequestStageContainer requestStageContainer,
                Boolean manageIdentities)
Deletes the set of filtered principals and keytabs from the cluster. 
 | 
RequestStageContainer | 
KerberosHelperImpl.deleteTestIdentity(Cluster cluster,
                  Map<String,String> commandParamsStage,
                  RequestStageContainer requestStageContainer)  | 
RequestStageContainer | 
KerberosHelper.deleteTestIdentity(Cluster cluster,
                  Map<String,String> commandParamsStage,
                  RequestStageContainer requestStageContainer)
Deletes the unique identity to use for testing the general Kerberos configuration. 
 | 
protected RequestStageContainer | 
AmbariManagementControllerImpl.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)  | 
boolean | 
KerberosHelperImpl.ensureHeadlessIdentities(Cluster cluster,
                        Map<String,Map<String,String>> existingConfigurations,
                        Set<String> services)  | 
boolean | 
KerberosHelper.ensureHeadlessIdentities(Cluster cluster,
                        Map<String,Map<String,String>> existingConfigurations,
                        Set<String> services)
Ensures that the relevant headless (or user) Kerberos identities are created and cached. 
 | 
RequestStageContainer | 
KerberosHelperImpl.ensureIdentities(Cluster cluster,
                Map<String,? extends Collection<String>> serviceComponentFilter,
                Set<String> hostFilter,
                Collection<String> identityFilter,
                Set<String> hostsToForceKerberosOperations,
                RequestStageContainer requestStageContainer,
                Boolean manageIdentities)  | 
RequestStageContainer | 
KerberosHelper.ensureIdentities(Cluster cluster,
                Map<String,? extends Collection<String>> serviceComponentFilter,
                Set<String> hostFilter,
                Collection<String> identityFilter,
                Set<String> hostsToForceKerberosOperations,
                RequestStageContainer requestStageContainer,
                Boolean manageIdentities)
Ensures the set of filtered principals and keytabs exist on the cluster. 
 | 
RequestStageContainer | 
KerberosHelperImpl.executeCustomOperations(Cluster cluster,
                       Map<String,String> requestProperties,
                       RequestStageContainer requestStageContainer,
                       Boolean manageIdentities)  | 
RequestStageContainer | 
KerberosHelper.executeCustomOperations(Cluster cluster,
                       Map<String,String> requestProperties,
                       RequestStageContainer requestStageContainer,
                       Boolean manageIdentities)
Used to execute custom security operations which are sent as directives in URI 
 | 
protected void | 
AmbariManagementControllerImpl.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>> | 
AmbariManagementController.findConfigurationTagsWithOverrides(Cluster cluster,
                                  String hostName)
Find configuration tags with applied overrides 
 | 
Map<String,Map<String,String>> | 
AmbariManagementControllerImpl.findConfigurationTagsWithOverrides(Cluster cluster,
                                  String hostName)  | 
String | 
AmbariManagementController.findServiceName(Cluster cluster,
               String componentName)
Get service name by cluster instance and component name 
 | 
String | 
AmbariManagementControllerImpl.findServiceName(Cluster cluster,
               String componentName)  | 
protected ServiceComponent | 
AmbariManagementControllerImpl.getClientComponentForRunningAction(Cluster cluster,
                                  Service service)  | 
protected String | 
AmbariManagementControllerImpl.getClientHostForRunningAction(Cluster cluster,
                             Service service,
                             ServiceComponent serviceComponent)  | 
MetadataUpdateEvent | 
AmbariManagementControllerImpl.getClusterMetadata(Cluster cl)  | 
MetadataUpdateEvent | 
AmbariManagementController.getClusterMetadataOnConfigsUpdate(Cluster cluster)  | 
MetadataUpdateEvent | 
AmbariManagementControllerImpl.getClusterMetadataOnConfigsUpdate(Cluster cl)  | 
MetadataUpdateEvent | 
AmbariManagementControllerImpl.getClusterMetadataOnRepoUpdate(Cluster cl)  | 
MetadataUpdateEvent | 
AmbariManagementControllerImpl.getClusterMetadataOnServiceCredentialStoreUpdate(Cluster cl,
                                                String serviceName)  | 
MetadataUpdateEvent | 
AmbariManagementControllerImpl.getClusterMetadataOnServiceInstall(Cluster cl,
                                  String serviceName)  | 
ExecuteCommandJson | 
AmbariCustomCommandExecutionHelper.getCommandJson(ActionExecutionContext actionExecContext,
              Cluster cluster,
              StackId stackId,
              String requestContext)
Helper method to fill execution command information. 
 | 
ExecutionCommand | 
AmbariManagementController.getExecutionCommand(Cluster cluster,
                   ServiceComponentHost scHost,
                   RoleCommand roleCommand)
Gets an execution command for host component life cycle command 
 | 
ExecutionCommand | 
AmbariManagementControllerImpl.getExecutionCommand(Cluster cluster,
                   ServiceComponentHost scHost,
                   RoleCommand roleCommand)  | 
Set<String> | 
KerberosHelperImpl.getHostsWithValidKerberosClient(Cluster cluster)  | 
Set<String> | 
KerberosHelper.getHostsWithValidKerberosClient(Cluster cluster)  | 
String | 
AmbariManagementController.getJobTrackerHost(Cluster cluster)
Deprecated.  
 | 
String | 
AmbariManagementControllerImpl.getJobTrackerHost(Cluster cluster)  | 
KerberosDescriptor | 
KerberosHelperImpl.getKerberosDescriptor(Cluster cluster,
                     boolean includePreconfigureData)  | 
KerberosDescriptor | 
KerberosHelper.getKerberosDescriptor(Cluster cluster,
                     boolean includePreconfigureData)
Builds a composite Kerberos descriptor using the default Kerberos descriptor and a user-specified
 Kerberos descriptor, if it exists. 
 | 
KerberosDescriptor | 
KerberosHelperImpl.getKerberosDescriptor(KerberosHelper.KerberosDescriptorType kerberosDescriptorType,
                     Cluster cluster,
                     boolean evaluateWhenClauses,
                     Collection<String> additionalServices,
                     boolean includePreconfigureData)  | 
KerberosDescriptor | 
KerberosHelper.getKerberosDescriptor(KerberosHelper.KerberosDescriptorType kerberosDescriptorType,
                     Cluster cluster,
                     boolean evaluateWhenClauses,
                     Collection<String> additionalServices,
                     boolean includePreconfigureData)
Gets the requested Kerberos descriptor. 
 | 
KerberosDescriptor | 
KerberosHelperImpl.getKerberosDescriptor(KerberosHelper.KerberosDescriptorType kerberosDescriptorType,
                     Cluster cluster,
                     StackId stackId,
                     boolean includePreconfigureData)  | 
KerberosDescriptor | 
KerberosHelper.getKerberosDescriptor(KerberosHelper.KerberosDescriptorType kerberosDescriptorType,
                     Cluster cluster,
                     StackId stackId,
                     boolean includePreconfigureData)
Gets the Kerberos descriptor for the requested stack. 
 | 
KerberosDetails | 
KerberosHelperImpl.getKerberosDetails(Cluster cluster,
                  Boolean manageIdentities)
Gathers the Kerberos-related data from configurations and stores it in a new KerberosDetails
 instance. 
 | 
KerberosDetails | 
KerberosHelper.getKerberosDetails(Cluster cluster,
                  Boolean manageIdentities)
Gathers the Kerberos-related data from configurations and stores it in a new KerberosDetails
 instance. 
 | 
Set<Map<String,String>> | 
MaintenanceStateHelper.getMaintenanceHostComponents(Clusters clusters,
                            Cluster cluster)  | 
TreeMap<String,String> | 
AmbariManagementControllerImpl.getMetadataClusterLevelParams(Cluster cluster,
                             StackId stackId)  | 
TreeMap<String,MetadataServiceInfo> | 
AmbariManagementControllerImpl.getMetadataServiceLevelParams(Cluster cluster)  | 
RoleCommandOrder | 
AmbariManagementController.getRoleCommandOrder(Cluster cluster)
Get Role Command Order 
 | 
RoleCommandOrder | 
AmbariManagementControllerImpl.getRoleCommandOrder(Cluster cluster)  | 
List<ServiceComponentHost> | 
KerberosHelperImpl.getServiceComponentHostsToProcess(Cluster cluster,
                                 KerberosDescriptor kerberosDescriptor,
                                 Map<String,? extends Collection<String>> serviceComponentFilter,
                                 Collection<String> hostFilter)  | 
List<ServiceComponentHost> | 
KerberosHelper.getServiceComponentHostsToProcess(Cluster cluster,
                                 KerberosDescriptor kerberosDescriptor,
                                 Map<String,? extends Collection<String>> serviceComponentFilter,
                                 Collection<String> hostFilter)  | 
Map<String,Map<String,String>> | 
KerberosHelperImpl.getServiceConfigurationUpdates(Cluster cluster,
                              Map<String,Map<String,String>> existingConfigurations,
                              Map<String,Set<String>> installedServices,
                              Map<String,Collection<String>> serviceFilter,
                              Set<String> previouslyExistingServices,
                              boolean kerberosEnabled,
                              boolean applyStackAdvisorUpdates)  | 
Map<String,Map<String,String>> | 
KerberosHelper.getServiceConfigurationUpdates(Cluster cluster,
                              Map<String,Map<String,String>> existingConfigurations,
                              Map<String,Set<String>> installedServices,
                              Map<String,Collection<String>> serviceFilter,
                              Set<String> previouslyExistingServices,
                              boolean kerberosEnabled,
                              boolean applyStackAdvisorUpdates)
Returns the updates configurations that are expected when the given set of services are configured
 for Kerberos. 
 | 
void | 
AmbariManagementController.initializeWidgetsAndLayouts(Cluster cluster,
                           Service service)
Initialize cluster scoped widgets and widgetLayouts for different stack
 components. 
 | 
void | 
AmbariManagementControllerImpl.initializeWidgetsAndLayouts(Cluster cluster,
                           Service service)  | 
boolean | 
KerberosHelperImpl.isClusterKerberosEnabled(Cluster cluster)  | 
boolean | 
KerberosHelper.isClusterKerberosEnabled(Cluster cluster)
Determine if a cluster has kerberos enabled. 
 | 
boolean | 
MaintenanceStateHelper.isOperationAllowed(Cluster cluster,
                  RequestOperationLevel levelObj,
                  RequestResourceFilter reqFilter,
                  String serviceName,
                  String componentName,
                  String hostname)  | 
Map<String,Map<String,String>> | 
KerberosHelperImpl.processPreconfiguredServiceConfigurations(Map<String,Map<String,String>> configurations,
                                         Map<String,Map<String,String>> replacements,
                                         Cluster cluster,
                                         KerberosDescriptor kerberosDescriptor)  | 
Map<String,Map<String,String>> | 
KerberosHelper.processPreconfiguredServiceConfigurations(Map<String,Map<String,String>> configurations,
                                         Map<String,Map<String,String>> replacements,
                                         Cluster cluster,
                                         KerberosDescriptor kerberosDescriptor)
Determines which services, not currently installed, should be preconfigured to aid in reducing
 the number of service restarts when new services are added to a cluster where Kerberos is enabled. 
 | 
void | 
KerberosHelperImpl.setAuthToLocalRules(Cluster cluster,
                   KerberosDescriptor kerberosDescriptor,
                   String realm,
                   Map<String,Set<String>> installedServices,
                   Map<String,Map<String,String>> existingConfigurations,
                   Map<String,Map<String,String>> kerberosConfigurations,
                   boolean includePreconfigureData)  | 
void | 
KerberosHelper.setAuthToLocalRules(Cluster cluster,
                   KerberosDescriptor kerberosDescriptor,
                   String realm,
                   Map<String,Set<String>> installedServices,
                   Map<String,Map<String,String>> existingConfigurations,
                   Map<String,Map<String,String>> kerberosConfigurations,
                   boolean includePreconfigureData)
Sets the relevant auth-to-local rule configuration properties using the services installed on
 the cluster and their relevant Kerberos descriptors to determine the rules to be created. 
 | 
RequestStageContainer | 
KerberosHelperImpl.toggleKerberos(Cluster cluster,
              SecurityType securityType,
              RequestStageContainer requestStageContainer,
              Boolean manageIdentities)  | 
RequestStageContainer | 
KerberosHelper.toggleKerberos(Cluster cluster,
              SecurityType securityType,
              RequestStageContainer requestStageContainer,
              Boolean manageIdentities)
Toggles Kerberos security to enable it or remove it depending on the state of the cluster. 
 | 
protected void | 
AmbariManagementControllerImpl.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 | 
AmbariManagementControllerImpl.validateAuthorizationToUpdateServiceUsersAndGroups(Cluster cluster,
                                                  String configType,
                                                  Map<String,String[]> propertyChanges)
Validates that the authenticated user can set a service's (run-as) user and group. 
 | 
void | 
KerberosHelperImpl.validateKDCCredentials(Cluster cluster)  | 
void | 
KerberosHelper.validateKDCCredentials(Cluster cluster)
Validate the KDC admin credentials. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected Set<RecommendationResponse.ConfigGroup> | 
StackAdvisorResourceProvider.calculateConfigGroups(Cluster cluster,
                     Request request)  | 
protected Map<String,Map<String,Map<String,String>>> | 
StackAdvisorResourceProvider.calculateConfigurations(Cluster cluster,
                       String serviceName)  | 
abstract String | 
HttpPropertyProvider.HttpPropertyRequest.getUrl(Cluster cluster,
      String hostName)
Get the URL used to make the HTTP request. 
 | 
String | 
ResourceManagerHttpPropertyRequest.getUrl(Cluster cluster,
      String hostName)  | 
String | 
AtlasServerHttpPropertyRequest.getUrl(Cluster cluster,
      String hostName)  | 
| Constructor and Description | 
|---|
LoggingRequestHelperImpl(String hostName,
                        String portNumber,
                        String protocol,
                        CredentialStoreService credentialStoreService,
                        Cluster cluster,
                        String externalAddress)  | 
LoggingRequestHelperImpl(String hostName,
                        String portNumber,
                        String protocol,
                        CredentialStoreService credentialStoreService,
                        Cluster cluster,
                        String externalAddress,
                        org.apache.ambari.server.controller.logging.LoggingRequestHelperImpl.NetworkConnection networkConnection)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected String | 
RestMetricsPropertyProvider.resolvePort(Cluster cluster,
           String hostname,
           String componentName,
           Map<String,String> metricsProperties,
           String protocol)
If protocol is equal to HTTPS_PROTOCOL than returns HTTPS_PORT_PROPERTY_NAME_PROPERTY value from PORT_CONFIG_TYPE_PROPERTY
 else uses port_config_type, port_property_name, default_port parameters from
 metricsProperties to find out right port value for service 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static RemovableIdentities | 
RemovableIdentities.ofComponent(Cluster cluster,
           ServiceComponentUninstalledEvent event,
           KerberosHelper kerberosHelper)
Populate the identities with the identities of the removed component 
 | 
static RemovableIdentities | 
RemovableIdentities.ofService(Cluster cluster,
         ServiceRemovedEvent event,
         KerberosHelper kerberosHelper)
Populate the identities with the identities of the removed service and its components 
 | 
static UsedIdentities | 
UsedIdentities.populate(Cluster cluster,
        UsedIdentities.ServiceExclude serviceExclude,
        UsedIdentities.ComponentExclude componentExclude,
        KerberosHelper kerberosHelper)
Get all identities of the installed services and components. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected Cluster | 
DefaultServiceCalculatedState.getCluster(String clusterName)  | 
| Modifier and Type | Field and Description | 
|---|---|
protected Cluster | 
StackUpgradeFinishEvent.cluster  | 
protected Cluster | 
HostComponentVersionAdvertisedEvent.cluster  | 
| Modifier and Type | Method and Description | 
|---|---|
Cluster | 
StackUpgradeFinishEvent.getCluster()  | 
Cluster | 
HostComponentVersionAdvertisedEvent.getCluster()  | 
| Constructor and Description | 
|---|
ConfigsUpdateEvent(Cluster cluster,
                  Collection<ClusterConfigEntity> configs)  | 
HostComponentVersionAdvertisedEvent(Cluster cluster,
                                   ServiceComponentHost sch,
                                   String version)
Constructor. 
 | 
HostComponentVersionAdvertisedEvent(Cluster cluster,
                                   ServiceComponentHost sch,
                                   String version,
                                   Long repoVersionId)
Constructor. 
 | 
StackUpgradeFinishEvent(Cluster cluster)
Constructor. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
RoleCommandOrder | 
CachedRoleCommandOrderProvider.getRoleCommandOrder(Cluster cluster)  | 
RoleCommandOrder | 
RoleCommandOrderProvider.getRoleCommandOrder(Cluster cluster)  | 
void | 
RoleCommandOrder.initialize(Cluster cluster,
          LinkedHashSet<String> sectionKeys)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected void | 
PropertiesEncryptor.encrypt(Map<String,String> configProperties,
       Cluster cluster,
       String configType)  | 
protected void | 
PropertiesEncryptor.encrypt(Map<String,String> configProperties,
       Cluster cluster,
       String configType,
       Function<String,String> encryption)  | 
protected void | 
PropertiesEncryptor.encrypt(Map<String,String> configProperties,
       Cluster cluster,
       String configType,
       String encryptionKey)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected Cluster | 
KerberosServerAction.getCluster()
Returns the relevant Cluster object 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected KerberosDescriptor | 
PrepareKerberosIdentitiesServerAction.getKerberosDescriptor(Cluster cluster,
                     boolean includePreconfigureData)
 | 
void | 
AbstractPrepareKerberosServerAction.processServiceComponentHosts(Cluster cluster,
                            KerberosDescriptor kerberosDescriptor,
                            List<ServiceComponentHost> schToProcess,
                            Collection<String> identityFilter,
                            String dataDirectory,
                            Map<String,Map<String,String>> currentConfigurations,
                            Map<String,Map<String,String>> kerberosConfigurations,
                            boolean includeAmbariIdentity,
                            Map<String,Set<String>> propertiesToBeIgnored)  | 
protected void | 
AbstractPrepareKerberosServerAction.processServiceComponents(Cluster cluster,
                        KerberosDescriptor kerberosDescriptor,
                        List<Component> schToProcess,
                        Collection<String> identityFilter,
                        String dataDirectory,
                        Map<String,Map<String,String>> currentConfigurations,
                        Map<String,Map<String,String>> kerberosConfigurations,
                        boolean includeAmbariIdentity,
                        Map<String,Set<String>> propertiesToBeIgnored)  | 
| Modifier and Type | Method and Description | 
|---|---|
Map<String,Collection<String>> | 
KerberosKeytabController.adjustServiceComponentFilter(Cluster cluster,
                            boolean includeAmbariAsService,
                            Map<String,? extends Collection<String>> serviceComponentFilter)
Adjust service component filter according to installed services 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected UpgradeContext | 
AbstractUpgradeServerAction.getUpgradeContext(Cluster cluster)
Gets an initialized  
UpgradeContext for the in-progress upgrade. | 
| Modifier and Type | Method and Description | 
|---|---|
Cluster | 
MasterHostResolver.getCluster()
Gets the cluster that this instance of the  
MasterHostResolver is
 initialized with. | 
| Modifier and Type | Method and Description | 
|---|---|
static List<NameService> | 
NameService.fromConfig(ConfigHelper config,
          Cluster cluster)  | 
static NameService.NameNode | 
NameService.NameNode.fromConfig(String nameServiceId,
          String nnUniqueId,
          ConfigHelper config,
          Cluster cluster)  | 
static Collection<Host> | 
MasterHostResolver.getCandidateHosts(Cluster cluster,
                 ExecuteHostType executeHostType,
                 String serviceName,
                 String componentName)
Gets hosts which match the supplied criteria. 
 | 
static HostsType | 
HostsType.healthy(Cluster cluster)
Create an instance with all healthy hosts. 
 | 
| Constructor and Description | 
|---|
MasterHostResolver(Cluster cluster,
                  ConfigHelper configHelper,
                  UpgradeContext upgradeContext)
Constructor. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
RepositoryVersionHelper.addRepoInfoToHostLevelParams(Cluster cluster,
                            ActionExecutionContext actionContext,
                            RepositoryVersionEntity repositoryVersion,
                            Map<String,String> hostLevelParams,
                            String hostName)
Deprecated.  
 | 
CommandRepository | 
RepositoryVersionHelper.getCommandRepository(Cluster cluster,
                    ServiceComponent component,
                    Host host)
Builds repository information for inclusion in a command. 
 | 
CommandRepository | 
RepositoryVersionHelper.getCommandRepository(Cluster cluster,
                    Service service,
                    Host host,
                    String componentName)  | 
Map<String,String> | 
ConfigureTask.getConfigurationChanges(Cluster cluster,
                       ConfigUpgradePack configUpgradePack)
Gets a map containing the following properties pertaining to the
 configuration value to change:
 
  
ConfigureTask.PARAMETER_CONFIG_TYPE - the configuration type (ie hdfs-site)
 ConfigureTask.PARAMETER_KEY_VALUE_PAIRS - key/value pairs for the
 configurations
 ConfigureTask.PARAMETER_KEY_VALUE_PAIRS - key/value pairs for the
 configurations
 ConfigureTask.PARAMETER_TRANSFERS - COPY/MOVE/DELETE changes
 ConfigureTask.PARAMETER_REPLACEMENTS - value replacements
  | 
List<ConfigUpgradeChangeDefinition.Replace> | 
ConfigUpgradeChangeDefinition.getRegexReplacements(Cluster cluster)
Evaluates the  
ConfigUpgradeChangeDefinition.RegexReplace instances defined for the upgrade and
 converts them into distinct ConfigUpgradeChangeDefinition.Replace objects. | 
String | 
RepositoryVersionHelper.getRepoInfo(Cluster cluster,
           ServiceComponent component,
           Host host)
Deprecated. 
 
 | 
String | 
RepositoryVersionHelper.getRepoInfoString(Cluster cluster,
                 ServiceComponent component,
                 Host host)
Get repository info given a cluster and host. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Cluster | 
UpgradeContext.getCluster()
Gets the cluster that the upgrade is for. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
UpgradeContext | 
UpgradeContextFactory.create(Cluster cluster,
      Map<String,Object> upgradeRequestMap)
Creates an  
UpgradeContext which is injected with dependencies. | 
UpgradeContext | 
UpgradeContextFactory.create(Cluster cluster,
      UpgradeEntity upgradeEntity)
Creates an  
UpgradeContext which is injected with dependencies. | 
| Constructor and Description | 
|---|
UpgradeContext(Cluster cluster,
              Map<String,Object> upgradeRequestMap,
              com.google.gson.Gson gson,
              UpgradeHelper upgradeHelper,
              UpgradeDAO upgradeDAO,
              RepositoryVersionDAO repoVersionDAO,
              ConfigHelper configHelper,
              AmbariMetaInfo metaInfo)  | 
UpgradeContext(Cluster cluster,
              UpgradeEntity upgradeEntity,
              AmbariMetaInfo ambariMetaInfo,
              ConfigHelper configHelper)
Constructor. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Cluster | 
Service.getCluster()  | 
Cluster | 
Config.getCluster()  | 
Cluster | 
ServiceImpl.getCluster()  | 
Cluster | 
ConfigImpl.getCluster()  | 
Cluster | 
Clusters.getCluster(Long clusterId)
Gets the Cluster given the cluster id 
 | 
Cluster | 
Clusters.getCluster(String clusterName)
Gets the Cluster given the cluster name 
 | 
Cluster | 
Clusters.getClusterById(long id)
Gets the cluster using the id. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Map<String,Cluster> | 
Clusters.getClusters()
Get all clusters 
 | 
Set<Cluster> | 
Clusters.getClustersForHost(String hostname)
Returns all the cluster names for this hostname 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Collection<String> | 
ServiceComponentSupport.allUnsupported(Cluster cluster,
              String stackName,
              String stackVersion)  | 
org.apache.commons.lang3.tuple.Pair<Map<String,Map<String,String>>,Map<String,Map<String,Map<String,String>>>> | 
ConfigHelper.calculateExistingConfigs(Cluster cluster)
Determines the existing configurations for the cluster, both properties and attributes. 
 | 
Map<String,Map<String,String>> | 
ConfigHelper.calculateExistingConfigurations(AmbariManagementController ambariManagementController,
                               Cluster cluster)
Determines the existing configurations for the cluster 
 | 
Map<String,Map<String,String>> | 
ConfigHelper.calculateExistingConfigurations(AmbariManagementController ambariManagementController,
                               Cluster cluster,
                               String hostname)
Determines the existing configurations for the cluster, related to a given hostname (if provided) 
 | 
void | 
ConfigHelper.checkAllStageConfigsPresentInDesiredConfigs(Cluster cluster)  | 
boolean | 
ConfigHelper.createConfigType(Cluster cluster,
                StackId stackId,
                AmbariManagementController controller,
                String configType,
                Map<String,String> properties,
                Map<String,Map<String,String>> propertyAttributes,
                String authenticatedUserName,
                String serviceVersionNote)  | 
void | 
ConfigHelper.createConfigType(Cluster cluster,
                StackId stackId,
                AmbariManagementController controller,
                String configType,
                Map<String,String> properties,
                String authenticatedUserName,
                String serviceVersionNote)  | 
boolean | 
ConfigHelper.createConfigTypes(Cluster cluster,
                 StackId stackId,
                 AmbariManagementController controller,
                 Map<String,Map<String,String>> batchProperties,
                 String authenticatedUserName,
                 String serviceVersionNote)
Create configurations and assign them for services. 
 | 
Config | 
ConfigFactory.createExisting(Cluster cluster,
              ClusterConfigEntity entity)
Creates a new  
Config object using provided entity | 
Service | 
ServiceFactory.createExisting(Cluster cluster,
              ClusterServiceEntity serviceEntity)
Creates an in-memory representation of a service from an existing database
 object. 
 | 
Service | 
ServiceFactory.createNew(Cluster cluster,
         String serviceName,
         RepositoryVersionEntity desiredRepositoryVersion)
Creates a new service in memory and then persists it to the database. 
 | 
Config | 
ConfigFactory.createNew(Cluster cluster,
         String type,
         String tag,
         Map<String,String> map,
         Map<String,Map<String,String>> mapAttributes)
Creates a new  
Config object using provided values. | 
Config | 
ConfigFactory.createNew(StackId stackId,
         Cluster cluster,
         String type,
         String tag,
         Map<String,String> map,
         Map<String,Map<String,String>> mapAttributes)
Creates a new  
Config object using provided values. | 
Map<String,Set<String>> | 
ConfigHelper.createUserGroupsMap(Cluster cluster,
                   Map<String,DesiredConfig> desiredConfigs,
                   Map<String,ServiceInfo> servicesMap,
                   Set<PropertyInfo> stackProperties)
Fetch user to group mapping from the cluster configs. 
 | 
Map<String,Set<String>> | 
ConfigHelper.createUserGroupsMap(StackId stackId,
                   Cluster cluster,
                   Map<String,DesiredConfig> desiredConfigs)
Fetch user to group mapping from the cluster configs. 
 | 
void | 
ConfigHelper.getAndMergeHostConfigAttributes(Map<String,Map<String,Map<String,String>>> configurationAttributes,
                               Map<String,Map<String,String>> configurationTags,
                               Cluster cluster)
Retrieves effective configuration attributes for specified cluster and tags and merge them with
 present before in  
configurationAttributes | 
void | 
ConfigHelper.getAndMergeHostConfigs(Map<String,Map<String,String>> configurations,
                      Map<String,Map<String,String>> configurationTags,
                      Cluster cluster)
Retrieves effective configurations for specified cluster and tags and merge them with
 present before in  
configurations | 
Map<String,Collection<String>> | 
ConfigHelper.getChangedConfigTypes(Cluster cluster,
                     ServiceConfigEntity currentServiceConfigEntity,
                     Long configGroupId,
                     Long clusterId,
                     String serviceName)
Calculates config types and keys were changed during configs change. 
 | 
Map<String,HostConfig> | 
Host.getDesiredHostConfigs(Cluster cluster,
                     Map<String,DesiredConfig> clusterDesiredConfigs)
Get the desired configurations for the host including overrides 
 | 
Map<String,Map<String,Map<String,String>>> | 
ConfigHelper.getEffectiveConfigAttributes(Cluster cluster,
                            Map<String,Map<String,String>> desiredTags)
Get all config attributes for a cluster given a set of configType to
 versionTags map. 
 | 
Map<String,Map<String,String>> | 
ConfigHelper.getEffectiveConfigProperties(Cluster cluster,
                            Map<String,Map<String,String>> desiredTags)
Get all config properties for a cluster given a set of configType to
 versionTags map. 
 | 
Map<String,Map<String,String>> | 
ConfigHelper.getEffectiveDesiredTags(Cluster cluster,
                       String hostName)
Gets the desired tags for a cluster and host 
 | 
Map<String,Map<String,String>> | 
ConfigHelper.getEffectiveDesiredTags(Cluster cluster,
                       String hostName,
                       Map<String,DesiredConfig> desiredConfigs)
Gets the desired tags for a cluster and host 
 | 
String | 
ConfigHelper.getPlaceholderValueFromDesiredConfigurations(Cluster cluster,
                                            String placeholder)
Gets the configuration value referenced by the specified placeholder from
 the cluster configuration. 
 | 
Map<PropertyInfo,String> | 
ConfigHelper.getPropertiesWithPropertyType(PropertyInfo.PropertyType propertyType,
                             Cluster cluster,
                             Map<String,DesiredConfig> desiredConfigs,
                             Map<String,ServiceInfo> servicesMap,
                             Set<PropertyInfo> stackProperties)
Fetch all the properties of a given PropertyType. 
 | 
Map<PropertyInfo,String> | 
ConfigHelper.getPropertiesWithPropertyType(StackId stackId,
                             PropertyInfo.PropertyType propertyType,
                             Cluster cluster,
                             Map<String,DesiredConfig> desiredConfigs)
Fetch all the properties of a given PropertyType. 
 | 
ServiceInfo | 
ConfigHelper.getPropertyOwnerService(Cluster cluster,
                       String configType,
                       String propertyName)  | 
String | 
ConfigHelper.getPropertyValueFromStackDefinitions(Cluster cluster,
                                    String configType,
                                    String propertyName)
Fetch all the config values of a given PropertyType. 
 | 
Set<String> | 
ConfigHelper.getPropertyValuesWithPropertyType(PropertyInfo.PropertyType propertyType,
                                 Cluster cluster,
                                 Map<String,DesiredConfig> desiredConfigs,
                                 Map<String,ServiceInfo> servicesMap,
                                 Set<PropertyInfo> stackProperties)
Fetch all the property values of a given PropertyType. 
 | 
Set<String> | 
ConfigHelper.getPropertyValuesWithPropertyType(StackId stackId,
                                 PropertyInfo.PropertyType propertyType,
                                 Cluster cluster,
                                 Map<String,DesiredConfig> desiredConfigs)
Fetch all the property values of a given PropertyType. 
 | 
String | 
ConfigHelper.getRefreshConfigsCommand(Cluster cluster,
                        ServiceComponentHost sch)  | 
String | 
ConfigHelper.getRefreshConfigsCommand(Cluster cluster,
                        String hostName,
                        String serviceName,
                        String componentName)  | 
Set<PropertyInfo> | 
ConfigHelper.getServiceProperties(Cluster cluster,
                    String serviceName)  | 
Set<PropertyInfo> | 
ConfigHelper.getStackProperties(Cluster cluster)  | 
String | 
ConfigHelper.getValueFromDesiredConfigurations(Cluster cluster,
                                 String configType,
                                 String propertyName)  | 
void | 
Clusters.invalidate(Cluster cluster)
Invalidates the specified cluster by retrieving it from the database and
 refreshing all of the internal stateful collections. 
 | 
void | 
ConfigHelper.removeConfigsByType(Cluster cluster,
                   String type)
Remove configs by type 
 | 
Set<ServiceComponent> | 
ServiceComponentSupport.unsupportedComponents(Cluster cluster,
                     String stackName,
                     String stackVersion)
Collects the ServiceComponents from the cluster which are not supported (component doesn't exist or was deleted) in the given stack. 
 | 
Set<String> | 
ServiceComponentSupport.unsupportedServices(Cluster cluster,
                   String stackName,
                   String stackVersion)
Collects the service names from the cluster which are not supported (service doesn't exist or was deleted) in the given stack. 
 | 
void | 
ConfigHelper.updateConfigType(Cluster cluster,
                StackId stackId,
                AmbariManagementController controller,
                String configType,
                Map<String,String> updates,
                Collection<String> removals,
                String authenticatedUserName,
                String serviceVersionNote)
A helper method to create a new  
Config for a given configuration
 type and updates to the current values, if any. | 
| Modifier and Type | Method and Description | 
|---|---|
Set<String> | 
AlertDefinitionHash.getAssociatedHosts(Cluster cluster,
                  SourceType definitionSourceType,
                  String definitionName,
                  String definitionServiceName,
                  String definitionComponentName)
Gets the hosts that are associated with the specified definition. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ClusterImpl  | 
| Modifier and Type | Method and Description | 
|---|---|
Cluster | 
ClusterFactory.create(ClusterEntity clusterEntity)  | 
protected Cluster | 
ClustersImpl.findCluster(String name)
Find the cluster for the given name. 
 | 
Cluster | 
ClustersImpl.getCluster(Long clusterId)  | 
Cluster | 
ClustersImpl.getCluster(String clusterName)  | 
Cluster | 
ClustersImpl.getClusterById(long id)  | 
| Modifier and Type | Method and Description | 
|---|---|
Map<String,Cluster> | 
ClustersImpl.getClusters()  | 
Set<Cluster> | 
ClustersImpl.getClustersForHost(String hostname)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ClustersImpl.invalidate(Cluster cluster)
Invalidates the specified cluster by retrieving it from the database and
 refreshing all of the internal stateful collections. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
ConfigGroup | 
ConfigGroupFactory.createExisting(Cluster cluster,
              ConfigGroupEntity entity)
Instantiates a  
ConfigGroup from an existing, persisted entity. | 
ConfigGroup | 
ConfigGroupFactory.createNew(Cluster cluster,
         String serviceName,
         String name,
         String tag,
         String description,
         Map<String,Config> configs,
         Map<Long,Host> hosts)
Creates and saves a new  
ConfigGroup. | 
| Constructor and Description | 
|---|
ConfigGroupImpl(Cluster cluster,
               ConfigGroupEntity configGroupEntity,
               Clusters clusters,
               ConfigFactory configFactory,
               ClusterDAO clusterDAO,
               HostDAO hostDAO,
               ConfigGroupDAO configGroupDAO,
               ConfigGroupConfigMappingDAO configGroupConfigMappingDAO,
               ConfigGroupHostMappingDAO configGroupHostMappingDAO,
               LockFactory lockFactory)  | 
ConfigGroupImpl(Cluster cluster,
               String serviceName,
               String name,
               String tag,
               String description,
               Map<String,Config> configurations,
               Map<Long,Host> hosts,
               Clusters clusters,
               ConfigFactory configFactory,
               ClusterDAO clusterDAO,
               HostDAO hostDAO,
               ConfigGroupDAO configGroupDAO,
               ConfigGroupConfigMappingDAO configGroupConfigMappingDAO,
               ConfigGroupHostMappingDAO configGroupHostMappingDAO,
               LockFactory lockFactory)  | 
| Modifier and Type | Method and Description | 
|---|---|
Map<String,HostConfig> | 
HostImpl.getDesiredHostConfigs(Cluster cluster,
                     Map<String,DesiredConfig> clusterDesiredConfigs)
Get the desired configurations for the host including overrides 
 | 
| Modifier and Type | Method and Description | 
|---|---|
ClusterVersionSummary | 
VersionDefinitionXml.getClusterSummary(Cluster cluster,
                 AmbariMetaInfo metaInfo)
Gets a summary for cluster given the version information in this version. 
 | 
Set<String> | 
VersionDefinitionXml.getMissingDependencies(Cluster cluster,
                      AmbariMetaInfo metaInfo)
Gets information about services which cannot be upgraded because the
 repository does not contain required dependencies. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
RequestExecution | 
RequestExecutionFactory.createExisting(Cluster cluster,
              RequestScheduleEntity requestScheduleEntity)  | 
RequestExecution | 
RequestExecutionFactory.createNew(Cluster cluster,
         Batch batch,
         Schedule schedule)  | 
| Constructor and Description | 
|---|
RequestExecutionImpl(Cluster cluster,
                    Batch batch,
                    Schedule schedule,
                    com.google.inject.Injector injector)  | 
RequestExecutionImpl(Cluster cluster,
                    RequestScheduleEntity requestScheduleEntity,
                    com.google.inject.Injector injector)  | 
| Modifier and Type | Method and Description | 
|---|---|
RequestValidator | 
RequestValidatorFactory.create(AddServiceRequest request,
      Cluster cluster)  | 
RequestStatusResponse | 
AddServiceOrchestrator.processAddServiceRequest(Cluster cluster,
                        AddServiceRequest request)  | 
| Constructor and Description | 
|---|
RequestValidator(AddServiceRequest request,
                Cluster cluster,
                AmbariManagementController controller,
                ConfigHelper configHelper,
                StackFactory stackFactory,
                KerberosDescriptorFactory kerberosDescriptorFactory,
                SecurityConfigurationFactory securityConfigurationFactory)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected Map<String,Cluster> | 
AbstractUpgradeCatalog.getCheckedClusterMap(Clusters clusters)
This method returns Map of clusters. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected void | 
UpgradeCatalog260.fixYarnHsiKerberosDescriptorAndSiteConfig(Cluster cluster,
                                         KerberosDescriptor kerberosDescriptor)
Updates YARN's NM 'llap_zk_hive' kerberos descriptor as reference and the associated config
 hive-interactive-site/hive.llap.zk.sm.keytab.file 
 | 
protected KerberosDescriptor | 
AbstractUpgradeCatalog.getKerberosDescriptor(Cluster cluster)
Retrieve the composite Kerberos Descriptor. 
 | 
protected static boolean | 
AbstractUpgradeCatalog.isConfigEnabled(Cluster cluster,
               String configType,
               String propertyName)  | 
protected boolean | 
AbstractUpgradeCatalog.isNNHAEnabled(Cluster cluster)  | 
protected boolean | 
AbstractUpgradeCatalog.isQueueNameValid(Cluster cluster,
                Set<String> validLeafQueues,
                String queueNameProperty,
                String configType)
Validate queueNameProperty exists for configType in cluster and corresponds to one of validLeafQueues 
 | 
protected void | 
AbstractUpgradeCatalog.removeConfigurationPropertiesFromCluster(Cluster cluster,
                                        String configType,
                                        Set<String> removePropertiesList)
Remove properties from the cluster 
 | 
protected void | 
AbstractUpgradeCatalog.updateConfigurationPropertiesForCluster(Cluster cluster,
                                       String configType,
                                       Map<String,String> properties,
                                       boolean updateIfExists,
                                       boolean createNewConfigType)  | 
protected void | 
AbstractUpgradeCatalog.updateConfigurationPropertiesForCluster(Cluster cluster,
                                       String configType,
                                       Map<String,String> properties,
                                       Set<String> removePropertiesList,
                                       boolean updateIfExists,
                                       boolean createNewConfigType)
Update properties for the cluster 
 | 
protected void | 
AbstractUpgradeCatalog.updateQueueName(Cluster cluster,
               Set<String> validLeafQueues,
               String queueNameProperty,
               String configType)
Update property queueNameProperty from configType of cluster to first of validLeafQueues 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static Set<Cluster> | 
RetryHelper.getAffectedClusters()  | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
RetryHelper.addAffectedCluster(Cluster cluster)  | 
static Map<String,Set<String>> | 
StageUtils.getClusterHostInfo(Cluster cluster)  | 
static void | 
SecretReference.replaceReferencesWithPasswords(Map<String,String> targetMap,
                              Cluster cluster)
Replace secret references with appropriate real passwords. 
 | 
| Constructor and Description | 
|---|
SecretReference(String reference,
               Cluster cluster)  | 
| Constructor and Description | 
|---|
ClusterImpl(Cluster cluster)
Create a view associated cluster from an Ambari cluster. 
 | 
Copyright © 2022 Apache Software Foundation. All rights reserved.