org.apache.ambari.server.upgrade

Class UpgradeCatalog252

java.lang.Object

org.apache.ambari.server.upgrade.AbstractUpgradeCatalog

org.apache.ambari.server.upgrade.UpgradeCatalog252

All Implemented Interfaces:

UpgradeCatalog

public class UpgradeCatalog252
extends AbstractUpgradeCatalog

The UpgradeCatalog252 upgrades Ambari from 2.5.1 to 2.5.2.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.ambari.server.upgrade.AbstractUpgradeCatalog

AbstractUpgradeCatalog.ConfigUpdateType, AbstractUpgradeCatalog.VersionComparator

Field Summary

Fields inherited from class org.apache.ambari.server.upgrade.AbstractUpgradeCatalog

ALERT_URL_PROPERTY_CONNECTION_TIMEOUT, ambariManagementController, ambariSequencesTable, ambariUpgradeConfigUpdatesFileName, AUTHENTICATED_USER_NAME, configuration, CONFIGURATION_TYPE_RANGER_HBASE_PLUGIN_PROPERTIES, CONFIGURATION_TYPE_RANGER_HIVE_PLUGIN_PROPERTIES, CONFIGURATION_TYPE_RANGER_KNOX_PLUGIN_PROPERTIES, dbAccessor, injector, PROPERTY_RANGER_HBASE_PLUGIN_ENABLED, PROPERTY_RANGER_HIVE_PLUGIN_ENABLED, PROPERTY_RANGER_KNOX_PLUGIN_ENABLED, QUEUES, YARN_SCHEDULER_CAPACITY_ROOT_QUEUE, YARN_SCHEDULER_CAPACITY_ROOT_QUEUES

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected void	executeDDLUpdates() Perform database schema transformation.
protected void	executeDMLUpdates() Performs normal data upgrade
protected void	executePreDMLUpdates() Perform data insertion before running normal upgrade of data, requires started persist service
String	getSourceVersion() Return latest source version that can be upgraded from.
String	getTargetVersion() Return the version that will be upgraded to
protected void	updateKerberosDescriptorArtifact(ArtifactDAO artifactDAO, ArtifactEntity artifactEntity) Update the specified Kerberos Descriptor artifact to conform to the new structure.

Methods inherited from class org.apache.ambari.server.upgrade.AbstractUpgradeCatalog

addAuthorizationToRole, addAuthorizationToRole, addAuthorizationToRole, addConnectionTimeoutParamForWebAndMetricAlerts, addNewConfigurationsFromXml, addRoleAuthorization, addSequence, addSequences, changePostgresSearchPath, convertStringToDocument, executeInTransaction, fetchMaxId, getCapacitySchedulerLeafQueues, getCheckedClusterMap, getEntityManagerProvider, getKerberosDescriptor, getUpgradeCatalog, getUpgradeJsonOutput, isConfigEnabled, isFinal, isNNHAEnabled, isQueueNameValid, onPostUpgrade, preUpgradeData, registerCatalog, removeConfigurationPropertiesFromCluster, setConfigUpdatesFileName, toString, updateConfigurationProperties, updateConfigurationPropertiesForCluster, updateConfigurationPropertiesForCluster, updateConfigurationPropertiesWithValuesFromXml, updateConfigurationPropertiesWithValuesFromXml, updateDatabaseSchemaVersion, updateKerberosDescriptorArtifacts, updateKerberosDescriptorIdentityReferences, updateKerberosDescriptorIdentityReferences, updateMetaInfoVersion, updateQueueName, updateWidgetDefinitionsForService, upgradeData, upgradeSchema

Methods inherited from class java.lang.Object

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

Constructor Detail

UpgradeCatalog252

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

Constructor.

Parameters:

injector -

Method Detail

getSourceVersion

public String getSourceVersion()

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

Specified by:

getSourceVersion in interface UpgradeCatalog

Overrides:

getSourceVersion in class AbstractUpgradeCatalog

Returns:

null : default

getTargetVersion

public String getTargetVersion()

Return the version that will be upgraded to

Returns:

executeDDLUpdates

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

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

Specified by:

executeDDLUpdates in class AbstractUpgradeCatalog

Throws:

org.apache.ambari.server.AmbariException

SQLException

executePreDMLUpdates

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

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

Specified by:

executePreDMLUpdates in class AbstractUpgradeCatalog

Throws:

org.apache.ambari.server.AmbariException

SQLException

executeDMLUpdates

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

Performs normal data upgrade

Specified by:

executeDMLUpdates in class AbstractUpgradeCatalog

Throws:

org.apache.ambari.server.AmbariException

SQLException

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.

Overrides:

updateKerberosDescriptorArtifact in class AbstractUpgradeCatalog

Parameters:

artifactDAO - the ArtifactDAO to use to store the updated ArtifactEntity

artifactEntity - the ArtifactEntity to update

Throws:

org.apache.ambari.server.AmbariException