org.apache.ambari.server.upgrade

Class UpgradeCatalog251

java.lang.Object

org.apache.ambari.server.upgrade.AbstractUpgradeCatalog

org.apache.ambari.server.upgrade.UpgradeCatalog251

All Implemented Interfaces:

UpgradeCatalog

public class UpgradeCatalog251
extends AbstractUpgradeCatalog

The UpgradeCatalog251 upgrades Ambari from 2.5.0 to 2.5.1.

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	KAFKA_BROKER_CONFIG
protected static String	STORM_ENV_CONFIG

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
UpgradeCatalog251(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	updateKAFKAConfigs() Ensure that the updates from Ambari 2.4.0 are applied in the event the initial version is Ambari 2.5.0, since this Kafka change failed to make it into Ambari 2.5.0.
protected void	updateSTORMConfigs() Make sure storm-env changes are applied to anyone upgrading to HDP-2.6.1 Storm If the base version was before Ambari 2.5.0, this method should wind up doing nothing.

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

KAFKA_BROKER_CONFIG

protected static final String KAFKA_BROKER_CONFIG

See Also:

Constant Field Values

STORM_ENV_CONFIG

protected static final String STORM_ENV_CONFIG

See Also:

Constant Field Values

Constructor Detail

UpgradeCatalog251

@Inject
public UpgradeCatalog251(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

updateKAFKAConfigs

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

Ensure that the updates from Ambari 2.4.0 are applied in the event the initial version is Ambari 2.5.0, since this Kafka change failed to make it into Ambari 2.5.0. If the base version was before Ambari 2.5.0, this method should wind up doing nothing.

Throws:

org.apache.ambari.server.AmbariException

updateSTORMConfigs

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

Make sure storm-env changes are applied to anyone upgrading to HDP-2.6.1 Storm If the base version was before Ambari 2.5.0, this method should wind up doing nothing.

Throws:

org.apache.ambari.server.AmbariException