org.apache.ambari.server.upgrade

Class UpgradeCatalog272

java.lang.Object

org.apache.ambari.server.upgrade.AbstractUpgradeCatalog

org.apache.ambari.server.upgrade.UpgradeCatalog272

All Implemented Interfaces:

UpgradeCatalog

public class UpgradeCatalog272
extends AbstractUpgradeCatalog

The UpgradeCatalog272 upgrades Ambari from 2.7.1 to 2.7.2.

Nested Class Summary

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

AbstractUpgradeCatalog.ConfigUpdateType, AbstractUpgradeCatalog.VersionComparator

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	BLUEPRINT_PROVISIONING_STATE_COLUMN
protected static String	CLUSTERS_TABLE
protected static String	HOST_COMPONENT_DESIRED_STATE_TABLE

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
UpgradeCatalog272(com.google.inject.Injector injector)

Method Summary

Modifier and Type	Method and Description
protected void	createRoleAuthorizations()
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	moveBlueprintProvisioningState()
protected int	renameLdapSynchCollisionBehaviorValue()

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, updateKerberosDescriptorArtifact, 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

Field Detail

HOST_COMPONENT_DESIRED_STATE_TABLE

protected static final String HOST_COMPONENT_DESIRED_STATE_TABLE

See Also:

Constant Field Values

CLUSTERS_TABLE

protected static final String CLUSTERS_TABLE

See Also:

Constant Field Values

BLUEPRINT_PROVISIONING_STATE_COLUMN

protected static final String BLUEPRINT_PROVISIONING_STATE_COLUMN

See Also:

Constant Field Values

Constructor Detail

UpgradeCatalog272

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

Method Detail

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

Overrides:

getSourceVersion in class AbstractUpgradeCatalog

Returns:

null : default

getTargetVersion

public String getTargetVersion()

Description copied from interface: UpgradeCatalog

Return the version that will be upgraded to

Returns:

executeDDLUpdates

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

Description copied from class: AbstractUpgradeCatalog

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

Description copied from class: AbstractUpgradeCatalog

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

Description copied from class: AbstractUpgradeCatalog

Performs normal data upgrade

Specified by:

executeDMLUpdates in class AbstractUpgradeCatalog

Throws:

org.apache.ambari.server.AmbariException

SQLException

renameLdapSynchCollisionBehaviorValue

protected int renameLdapSynchCollisionBehaviorValue()
                                             throws SQLException

Throws:

SQLException

createRoleAuthorizations

protected void createRoleAuthorizations()
                                 throws SQLException

Throws:

SQLException

moveBlueprintProvisioningState

protected void moveBlueprintProvisioningState()
                                       throws SQLException

Throws:

SQLException