org.apache.ambari.server.upgrade

Class AbstractUpgradeCatalog

java.lang.Object

org.apache.ambari.server.upgrade.AbstractUpgradeCatalog

All Implemented Interfaces:

UpgradeCatalog

Direct Known Subclasses:

AbstractFinalUpgradeCatalog, UpgradeCatalog251, UpgradeCatalog252, UpgradeCatalog260, UpgradeCatalog261, UpgradeCatalog262, UpgradeCatalog270, UpgradeCatalog271, UpgradeCatalog272, UpgradeCatalog274, UpgradeCatalog275, UpgradeCatalog280

public abstract class AbstractUpgradeCatalog
extends Object
implements UpgradeCatalog

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractUpgradeCatalog.ConfigUpdateType
protected static class	AbstractUpgradeCatalog.VersionComparator

Field Summary

Fields

Modifier and Type	Field and Description
static String	ALERT_URL_PROPERTY_CONNECTION_TIMEOUT
protected AmbariManagementControllerImpl	ambariManagementController
protected String	ambariSequencesTable Override variable in child's if table name was changed
protected String	ambariUpgradeConfigUpdatesFileName
protected static String	AUTHENTICATED_USER_NAME The user name to use as the authenticated user when perform authenticated tasks or operations that require the name of the authenticated user
protected Configuration	configuration
static String	CONFIGURATION_TYPE_RANGER_HBASE_PLUGIN_PROPERTIES
static String	CONFIGURATION_TYPE_RANGER_HIVE_PLUGIN_PROPERTIES
static String	CONFIGURATION_TYPE_RANGER_KNOX_PLUGIN_PROPERTIES
protected DBAccessor	dbAccessor
protected com.google.inject.Injector	injector
static String	PROPERTY_RANGER_HBASE_PLUGIN_ENABLED
static String	PROPERTY_RANGER_HIVE_PLUGIN_ENABLED
static String	PROPERTY_RANGER_KNOX_PLUGIN_ENABLED
static String	QUEUES
static String	YARN_SCHEDULER_CAPACITY_ROOT_QUEUE
static String	YARN_SCHEDULER_CAPACITY_ROOT_QUEUES

Constructor Summary

Constructors

Constructor and Description
AbstractUpgradeCatalog(com.google.inject.Injector injector)

Method Summary

Modifier and Type	Method and Description
protected void	addAuthorizationToRole(PermissionEntity role, String roleAuthorizationID) Add a new authorization to the set of authorizations for a role
protected void	addAuthorizationToRole(String roleName, String resourceType, RoleAuthorizationEntity roleAuthorization) Add a new authorization to the set of authorizations for a role
protected void	addAuthorizationToRole(String roleName, String resourceType, String roleAuthorizationID) Add a new authorization to the set of authorizations for a role
void	addConnectionTimeoutParamForWebAndMetricAlerts()
void	addNewConfigurationsFromXml()
protected void	addRoleAuthorization(String roleAuthorizationID, String roleAuthorizationName, Collection<String> applicableRoles) Add a new role authorization and optionally add it to 1 or more roles.
protected void	addSequence(String seqName, Long seqDefaultValue, boolean ignoreFailure) Add new sequence to ambariSequencesTable.
protected void	addSequences(List<String> seqNames, Long seqDefaultValue, boolean ignoreFailure) Add several new sequences to ambariSequencesTable.
protected void	changePostgresSearchPath()
protected static Document	convertStringToDocument(String xmlStr)
protected abstract void	executeDDLUpdates() Perform database schema transformation.
protected abstract void	executeDMLUpdates() Performs normal data upgrade
protected void	executeInTransaction(Runnable func)
protected abstract void	executePreDMLUpdates() Perform data insertion before running normal upgrade of data, requires started persist service
protected long	fetchMaxId(String tableName, String idColumnName) Fetches the maximum value of the given ID column from the given table.
protected Set<String>	getCapacitySchedulerLeafQueues(Map<String,String> capacitySchedulerMap) Pars Capacity Scheduler Properties and get all YARN Capacity Scheduler leaf queue names
protected Map<String,Cluster>	getCheckedClusterMap(Clusters clusters) This method returns Map of clusters.
protected com.google.inject.Provider<javax.persistence.EntityManager>	getEntityManagerProvider()
protected KerberosDescriptor	getKerberosDescriptor(Cluster cluster) Retrieve the composite Kerberos Descriptor.
String	getSourceVersion() Return latest source version that can be upgraded from.
protected static UpgradeCatalog	getUpgradeCatalog(String version)
Map<String,String>	getUpgradeJsonOutput()
protected static boolean	isConfigEnabled(Cluster cluster, String configType, String propertyName)
boolean	isFinal() Defines if Upgrade Catalog should be executed last
protected boolean	isNNHAEnabled(Cluster cluster)
protected boolean	isQueueNameValid(Cluster cluster, Set<String> validLeafQueues, String queueNameProperty, String configType) Validate queueNameProperty exists for configType in cluster and corresponds to one of validLeafQueues
void	onPostUpgrade() Called after UpgradeCatalog.upgradeSchema() and UpgradeCatalog.upgradeData(), this method is used to perform any operations after the catalog has finished.
void	preUpgradeData() perform data insertion before running normal upgrade of data, requires started persist service
protected void	registerCatalog(UpgradeCatalog upgradeCatalog) Every subclass needs to register itself
protected void	removeConfigurationPropertiesFromCluster(Cluster cluster, String configType, Set<String> removePropertiesList) Remove properties from the cluster
void	setConfigUpdatesFileName(String ambariUpgradeConfigUpdatesFileName) Set the file name, to store all config changes during upgrade
String	toString()
protected void	updateConfigurationProperties(String configType, Map<String,String> properties, boolean updateIfExists, boolean createNewConfigType) Create a new cluster scoped configuration with the new properties added to the existing set of properties.
protected void	updateConfigurationPropertiesForCluster(Cluster cluster, String configType, Map<String,String> properties, boolean updateIfExists, boolean createNewConfigType)
protected void	updateConfigurationPropertiesForCluster(Cluster cluster, String configType, Map<String,String> properties, Set<String> removePropertiesList, boolean updateIfExists, boolean createNewConfigType) Update properties for the cluster
protected void	updateConfigurationPropertiesWithValuesFromXml(String configType, Set<String> propertyNames, boolean updateIfExists, boolean createNewConfigType) Create a new cluster scoped configuration with the new properties added with the values from the coresponding xml files.
protected void	updateConfigurationPropertiesWithValuesFromXml(String configType, Set<String> propertyNames, Set<String> toRemove, boolean updateIfExists, boolean createNewConfigType)
void	updateDatabaseSchemaVersion() Update schema version in the database to the Target one
protected void	updateKerberosDescriptorArtifact(ArtifactDAO artifactDAO, ArtifactEntity artifactEntity) Update the specified Kerberos Descriptor artifact to conform to the new structure.
protected void	updateKerberosDescriptorArtifacts() Update the stored Kerberos Descriptor artifacts to conform to the new structure.
protected void	updateKerberosDescriptorIdentityReferences(AbstractKerberosDescriptorContainer descriptorContainer, String referenceName, String newReferenceName) Given an AbstractKerberosDescriptorContainer, iterates through its contained identity descriptors to find ones matching the reference name to change.
protected void	updateKerberosDescriptorIdentityReferences(Map<String,? extends AbstractKerberosDescriptorContainer> descriptorMap, String referenceName, String newReferenceName) Iterates through a collection of AbstractKerberosDescriptorContainers to find and update identity descriptor references.
int	updateMetaInfoVersion(String version) Update metainfo to new version.
protected void	updateQueueName(Cluster cluster, Set<String> validLeafQueues, String queueNameProperty, String configType) Update property queueNameProperty from configType of cluster to first of validLeafQueues
protected void	updateWidgetDefinitionsForService(String serviceName, Map<String,List<String>> widgetMap, Map<String,String> sectionLayoutMap)
void	upgradeData() perform data updates as necessary, requires started persist service
void	upgradeSchema() Run the upgrade scripts for upgrading ambari server from current version to the new version.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ambari.server.upgrade.UpgradeCatalog

getTargetVersion

Field Detail

dbAccessor

@Inject
protected DBAccessor dbAccessor

configuration

@Inject
protected Configuration configuration

ambariManagementController

@Inject
protected AmbariManagementControllerImpl ambariManagementController

injector

protected com.google.inject.Injector injector

ambariSequencesTable

protected String ambariSequencesTable

Override variable in child's if table name was changed

AUTHENTICATED_USER_NAME

protected static final String AUTHENTICATED_USER_NAME

The user name to use as the authenticated user when perform authenticated tasks or operations that require the name of the authenticated user

See Also:

Constant Field Values

CONFIGURATION_TYPE_RANGER_HBASE_PLUGIN_PROPERTIES

public static final String CONFIGURATION_TYPE_RANGER_HBASE_PLUGIN_PROPERTIES

See Also:

Constant Field Values

CONFIGURATION_TYPE_RANGER_KNOX_PLUGIN_PROPERTIES

public static final String CONFIGURATION_TYPE_RANGER_KNOX_PLUGIN_PROPERTIES

See Also:

Constant Field Values

CONFIGURATION_TYPE_RANGER_HIVE_PLUGIN_PROPERTIES

public static final String CONFIGURATION_TYPE_RANGER_HIVE_PLUGIN_PROPERTIES

See Also:

Constant Field Values

PROPERTY_RANGER_HBASE_PLUGIN_ENABLED

public static final String PROPERTY_RANGER_HBASE_PLUGIN_ENABLED

See Also:

Constant Field Values

PROPERTY_RANGER_KNOX_PLUGIN_ENABLED

public static final String PROPERTY_RANGER_KNOX_PLUGIN_ENABLED

See Also:

Constant Field Values

PROPERTY_RANGER_HIVE_PLUGIN_ENABLED

public static final String PROPERTY_RANGER_HIVE_PLUGIN_ENABLED

See Also:

Constant Field Values

YARN_SCHEDULER_CAPACITY_ROOT_QUEUE

public static final String YARN_SCHEDULER_CAPACITY_ROOT_QUEUE

See Also:

Constant Field Values

YARN_SCHEDULER_CAPACITY_ROOT_QUEUES

public static final String YARN_SCHEDULER_CAPACITY_ROOT_QUEUES

See Also:

Constant Field Values

QUEUES

public static final String QUEUES

See Also:

Constant Field Values

ALERT_URL_PROPERTY_CONNECTION_TIMEOUT

public static final String ALERT_URL_PROPERTY_CONNECTION_TIMEOUT

See Also:

Constant Field Values

ambariUpgradeConfigUpdatesFileName

protected String ambariUpgradeConfigUpdatesFileName

Constructor Detail

AbstractUpgradeCatalog

@Inject
public AbstractUpgradeCatalog(com.google.inject.Injector injector)

Method Detail

registerCatalog

protected void registerCatalog(UpgradeCatalog upgradeCatalog)

Every subclass needs to register itself

addSequence

protected final void addSequence(String seqName,
                                 Long seqDefaultValue,
                                 boolean ignoreFailure)
                          throws SQLException

Add new sequence to ambariSequencesTable.

Parameters:

seqName - name of sequence to be inserted

seqDefaultValue - initial value for the sequence

ignoreFailure - true to ignore insert sql errors

Throws:

SQLException

addSequences

protected final void addSequences(List<String> seqNames,
                                  Long seqDefaultValue,
                                  boolean ignoreFailure)
                           throws SQLException

Add several new sequences to ambariSequencesTable.

Parameters:

seqNames - list of sequences to be inserted

seqDefaultValue - initial value for the sequence

ignoreFailure - true to ignore insert sql errors

Throws:

SQLException

fetchMaxId

protected final long fetchMaxId(String tableName,
                                String idColumnName)
                         throws SQLException

Fetches the maximum value of the given ID column from the given table.

Parameters:

tableName - the name of the table to query the data from

idColumnName - the name of the ID column you want to query the maximum value for. This MUST refer an existing numeric type column

Returns:

the maximum value of the given column in the given table if any; 0L otherwise.

Throws:

SQLException

getSourceVersion

public String getSourceVersion()

Description copied from interface: UpgradeCatalog

Return latest source version that can be upgraded from. Return null since no UpgradeCatalogs exist before this one.

Specified by:

getSourceVersion in interface UpgradeCatalog

Returns:

null : default

getUpgradeCatalog

protected static UpgradeCatalog getUpgradeCatalog(String version)

convertStringToDocument

protected static Document convertStringToDocument(String xmlStr)

isConfigEnabled

protected static boolean isConfigEnabled(Cluster cluster,
                                         String configType,
                                         String propertyName)

getUpgradeJsonOutput

public Map<String,String> getUpgradeJsonOutput()

Specified by:

getUpgradeJsonOutput in interface UpgradeCatalog

updateMetaInfoVersion

public int updateMetaInfoVersion(String version)

Update metainfo to new version.

addConnectionTimeoutParamForWebAndMetricAlerts

public void addConnectionTimeoutParamForWebAndMetricAlerts()

getEntityManagerProvider

protected com.google.inject.Provider<javax.persistence.EntityManager> getEntityManagerProvider()

executeInTransaction

protected void executeInTransaction(Runnable func)

changePostgresSearchPath

protected void changePostgresSearchPath()
                                 throws SQLException

Throws:

SQLException

addNewConfigurationsFromXml

public void addNewConfigurationsFromXml()
                                 throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

isNNHAEnabled

protected boolean isNNHAEnabled(Cluster cluster)

getCheckedClusterMap

protected Map<String,Cluster> getCheckedClusterMap(Clusters clusters)

This method returns Map of clusters. Map can be empty or with some objects, but never be null.

updateConfigurationPropertiesWithValuesFromXml

protected void updateConfigurationPropertiesWithValuesFromXml(String configType,
                                                              Set<String> propertyNames,
                                                              boolean updateIfExists,
                                                              boolean createNewConfigType)
                                                       throws org.apache.ambari.server.AmbariException

Create a new cluster scoped configuration with the new properties added with the values from the coresponding xml files. If xml owner service is not in the cluster, the configuration won't be added.

Parameters:

configType - Configuration type. (hdfs-site, etc.)

propertyNames - Set property names.

Throws:

org.apache.ambari.server.AmbariException

updateConfigurationPropertiesWithValuesFromXml

protected void updateConfigurationPropertiesWithValuesFromXml(String configType,
                                                              Set<String> propertyNames,
                                                              Set<String> toRemove,
                                                              boolean updateIfExists,
                                                              boolean createNewConfigType)
                                                       throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

updateConfigurationPropertiesForCluster

protected void updateConfigurationPropertiesForCluster(Cluster cluster,
                                                       String configType,
                                                       Map<String,String> properties,
                                                       Set<String> removePropertiesList,
                                                       boolean updateIfExists,
                                                       boolean createNewConfigType)
                                                throws org.apache.ambari.server.AmbariException

Update properties for the cluster

Parameters:

cluster - cluster object

configType - config to be updated

properties - properties to be added or updated. Couldn't be null, but could be empty.

removePropertiesList - properties to be removed. Could be null

updateIfExists -

createNewConfigType -

Throws:

org.apache.ambari.server.AmbariException

updateConfigurationPropertiesForCluster

protected void updateConfigurationPropertiesForCluster(Cluster cluster,
                                                       String configType,
                                                       Map<String,String> properties,
                                                       boolean updateIfExists,
                                                       boolean createNewConfigType)
                                                throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

removeConfigurationPropertiesFromCluster

protected void removeConfigurationPropertiesFromCluster(Cluster cluster,
                                                        String configType,
                                                        Set<String> removePropertiesList)
                                                 throws org.apache.ambari.server.AmbariException

Remove properties from the cluster

Parameters:

cluster - cluster object

configType - config to be updated

removePropertiesList - properties to be removed. Could be null

Throws:

org.apache.ambari.server.AmbariException

updateConfigurationProperties

protected void updateConfigurationProperties(String configType,
                                             Map<String,String> properties,
                                             boolean updateIfExists,
                                             boolean createNewConfigType)
                                      throws org.apache.ambari.server.AmbariException

Create a new cluster scoped configuration with the new properties added to the existing set of properties.

Parameters:

configType - Configuration type. (hdfs-site, etc.)

properties - Map of key value pairs to add / update.

Throws:

org.apache.ambari.server.AmbariException

updateKerberosDescriptorIdentityReferences

protected void updateKerberosDescriptorIdentityReferences(Map<String,? extends AbstractKerberosDescriptorContainer> descriptorMap,
                                                          String referenceName,
                                                          String newReferenceName)

Iterates through a collection of AbstractKerberosDescriptorContainers to find and update identity descriptor references.

Parameters:

descriptorMap - a String to AbstractKerberosDescriptorContainer map to iterate trough

referenceName - the reference name to change

newReferenceName - the new reference name

updateKerberosDescriptorIdentityReferences

protected void updateKerberosDescriptorIdentityReferences(AbstractKerberosDescriptorContainer descriptorContainer,
                                                          String referenceName,
                                                          String newReferenceName)

Given an AbstractKerberosDescriptorContainer, iterates through its contained identity descriptors to find ones matching the reference name to change.

If found, the reference name is updated to the new name.

Parameters:

descriptorContainer - the AbstractKerberosDescriptorContainer to update

referenceName - the reference name to change

newReferenceName - the new reference name

updateKerberosDescriptorArtifacts

protected void updateKerberosDescriptorArtifacts()
                                          throws org.apache.ambari.server.AmbariException

Update the stored Kerberos Descriptor artifacts to conform to the new structure.

Finds the relevant artifact entities and iterates through them to process each independently.

Throws:

org.apache.ambari.server.AmbariException

getKerberosDescriptor

protected KerberosDescriptor getKerberosDescriptor(Cluster cluster)
                                            throws org.apache.ambari.server.AmbariException

Retrieve the composite Kerberos Descriptor.

The composite Kerberos Descriptor is the cluster's stack-specific Kerberos Descriptor overlaid with changes specified by the user via the cluster's Kerberos Descriptor artifact.

Parameters:

cluster - the relevant cluster

Returns:

the composite Kerberos Descriptor

Throws:

org.apache.ambari.server.AmbariException

addRoleAuthorization

protected void addRoleAuthorization(String roleAuthorizationID,
                                    String roleAuthorizationName,
                                    Collection<String> applicableRoles)
                             throws SQLException

Add a new role authorization and optionally add it to 1 or more roles.

The collection of roles to add the new role authorization to may be null or empty, indicating that no roles are to be altered. If set, though, each role entry in the collection must be a colon-delimited string like: ROLE:RESOURCE TYPE. Examples:

• "AMBARI.ADMINISTRATOR:AMBARI"
• "CLUSTER.ADMINISTRATOR:CLUSTER"
• "SERVICE.OPERATOR:CLUSTER"

Parameters:

roleAuthorizationID - the ID of the new authorization

roleAuthorizationName - the (descriptive) name of the new authorization

applicableRoles - an optional collection of role specification to add the new authorization to

Throws:

SQLException

addAuthorizationToRole

protected void addAuthorizationToRole(String roleName,
                                      String resourceType,
                                      String roleAuthorizationID)

Add a new authorization to the set of authorizations for a role

Parameters:

roleName - the name of the role

resourceType - the resource type of the role (AMBARI, CLUSTER, VIEW, etc...)

roleAuthorizationID - the ID of the authorization

See Also:

addAuthorizationToRole(String, String, RoleAuthorizationEntity)

addAuthorizationToRole

protected void addAuthorizationToRole(String roleName,
                                      String resourceType,
                                      RoleAuthorizationEntity roleAuthorization)

Add a new authorization to the set of authorizations for a role

Parameters:

roleName - the name of the role

resourceType - the resource type of the role (AMBARI, CLUSTER, VIEW, etc...)

roleAuthorization - the authorization to add

addAuthorizationToRole

protected void addAuthorizationToRole(PermissionEntity role,
                                      String roleAuthorizationID)

Add a new authorization to the set of authorizations for a role

Parameters:

role - the role to add the authorization to

roleAuthorizationID - the authorization to add

updateKerberosDescriptorArtifact

protected void updateKerberosDescriptorArtifact(ArtifactDAO artifactDAO,
                                                ArtifactEntity artifactEntity)
                                         throws org.apache.ambari.server.AmbariException

Update the specified Kerberos Descriptor artifact to conform to the new structure.

On ambari version update some of identities can be moved between scopes(e.g. from service to component), so old identity need to be moved to proper place and all references for moved identity need to be updated.

By default descriptor remains unchanged and this method must be overridden in child UpgradeCatalog to meet new ambari version changes in kerberos descriptors.

The supplied ArtifactEntity is updated in place a merged back into the database.

Parameters:

artifactDAO - the ArtifactDAO to use to store the updated ArtifactEntity

artifactEntity - the ArtifactEntity to update

Throws:

org.apache.ambari.server.AmbariException

upgradeSchema

public void upgradeSchema()
                   throws org.apache.ambari.server.AmbariException,
                          SQLException

Description copied from interface: UpgradeCatalog

Run the upgrade scripts for upgrading ambari server from current version to the new version.

Specified by:

upgradeSchema in interface UpgradeCatalog

Throws:

org.apache.ambari.server.AmbariException

SQLException

preUpgradeData

public void preUpgradeData()
                    throws org.apache.ambari.server.AmbariException,
                           SQLException

Description copied from interface: UpgradeCatalog

perform data insertion before running normal upgrade of data, requires started persist service

Specified by:

preUpgradeData in interface UpgradeCatalog

Throws:

org.apache.ambari.server.AmbariException

SQLException

setConfigUpdatesFileName

public void setConfigUpdatesFileName(String ambariUpgradeConfigUpdatesFileName)

Description copied from interface: UpgradeCatalog

Set the file name, to store all config changes during upgrade

Specified by:

setConfigUpdatesFileName in interface UpgradeCatalog

upgradeData

public void upgradeData()
                 throws org.apache.ambari.server.AmbariException,
                        SQLException

Description copied from interface: UpgradeCatalog

perform data updates as necessary, requires started persist service

Specified by:

upgradeData in interface UpgradeCatalog

Throws:

org.apache.ambari.server.AmbariException

SQLException

updateDatabaseSchemaVersion

public final void updateDatabaseSchemaVersion()

Description copied from interface: UpgradeCatalog

Update schema version in the database to the Target one

Specified by:

updateDatabaseSchemaVersion in interface UpgradeCatalog

isFinal

public boolean isFinal()

Description copied from interface: UpgradeCatalog

Defines if Upgrade Catalog should be executed last

Specified by:

isFinal in interface UpgradeCatalog

Returns:

executeDDLUpdates

protected abstract void executeDDLUpdates()
                                   throws org.apache.ambari.server.AmbariException,
                                          SQLException

Perform database schema transformation. Can work only before persist service start

Throws:

org.apache.ambari.server.AmbariException

SQLException

executePreDMLUpdates

protected abstract void executePreDMLUpdates()
                                      throws org.apache.ambari.server.AmbariException,
                                             SQLException

Perform data insertion before running normal upgrade of data, requires started persist service

Throws:

org.apache.ambari.server.AmbariException

SQLException

executeDMLUpdates

protected abstract void executeDMLUpdates()
                                   throws org.apache.ambari.server.AmbariException,
                                          SQLException

Performs normal data upgrade

Throws:

org.apache.ambari.server.AmbariException

SQLException

toString

public String toString()

Overrides:

toString in class Object

onPostUpgrade

public void onPostUpgrade()
                   throws org.apache.ambari.server.AmbariException,
                          SQLException

Called after UpgradeCatalog.upgradeSchema() and UpgradeCatalog.upgradeData(), this method is used to perform any operations after the catalog has finished. Usually, this is cleanup work that does not directly affect the upgrade.

Specified by:

onPostUpgrade in interface UpgradeCatalog

Throws:

org.apache.ambari.server.AmbariException

SQLException

isQueueNameValid

protected boolean isQueueNameValid(Cluster cluster,
                                   Set<String> validLeafQueues,
                                   String queueNameProperty,
                                   String configType)

Validate queueNameProperty exists for configType in cluster and corresponds to one of validLeafQueues

Parameters:

cluster - cluster to operate with

validLeafQueues - Set of YARN capacity-scheduler leaf queues

queueNameProperty - queue name property to check and update

configType - config type name

Returns:

updateQueueName

protected void updateQueueName(Cluster cluster,
                               Set<String> validLeafQueues,
                               String queueNameProperty,
                               String configType)
                        throws org.apache.ambari.server.AmbariException

Update property queueNameProperty from configType of cluster to first of validLeafQueues

Parameters:

cluster - cluster to operate with

validLeafQueues - Set of YARN capacity-scheduler leaf queues

queueNameProperty - queue name property to check and update

configType - config type name

Throws:

org.apache.ambari.server.AmbariException - if an error occurs while updating the configurations

getCapacitySchedulerLeafQueues

protected Set<String> getCapacitySchedulerLeafQueues(Map<String,String> capacitySchedulerMap)

Pars Capacity Scheduler Properties and get all YARN Capacity Scheduler leaf queue names

Parameters:

capacitySchedulerMap - capacity-scheduler properties map

Returns:

all YARN Capacity Scheduler leaf queue names

updateWidgetDefinitionsForService

protected void updateWidgetDefinitionsForService(String serviceName,
                                                 Map<String,List<String>> widgetMap,
                                                 Map<String,String> sectionLayoutMap)
                                          throws org.apache.ambari.server.AmbariException

Parameters:

serviceName -

widgetMap -

sectionLayoutMap -

Throws:

org.apache.ambari.server.AmbariException