org.apache.ambari.server.upgrade

Class UpgradeCatalog280

java.lang.Object

org.apache.ambari.server.upgrade.AbstractUpgradeCatalog

org.apache.ambari.server.upgrade.UpgradeCatalog280

All Implemented Interfaces:

UpgradeCatalog

public class UpgradeCatalog280
extends AbstractUpgradeCatalog

The UpgradeCatalog280 upgrades Ambari from 2.7.2 to 2.8.0.

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	AMBARI_CONFIGURATION_PROPERTY_VALUE_COLUMN
protected static String	AMBARI_CONFIGURATION_TABLE
protected static String	HOST_COMPONENT_STATE_TABLE
protected static String	LAST_LIVE_STATE_COLUMN

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

Method Summary

Modifier and Type	Method and Description
protected void	addColumnsToRequestScheduleTable()
protected void	addColumnsToUpgradeTable()
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	removeLastValidState()

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_STATE_TABLE

protected static final String HOST_COMPONENT_STATE_TABLE

See Also:

Constant Field Values

LAST_LIVE_STATE_COLUMN

protected static final String LAST_LIVE_STATE_COLUMN

See Also:

Constant Field Values

AMBARI_CONFIGURATION_TABLE

protected static final String AMBARI_CONFIGURATION_TABLE

See Also:

Constant Field Values

AMBARI_CONFIGURATION_PROPERTY_VALUE_COLUMN

protected static final String AMBARI_CONFIGURATION_PROPERTY_VALUE_COLUMN

See Also:

Constant Field Values

Constructor Detail

UpgradeCatalog280

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

addColumnsToRequestScheduleTable

protected void addColumnsToRequestScheduleTable()
                                         throws SQLException

Throws:

SQLException

addColumnsToUpgradeTable

protected void addColumnsToUpgradeTable()
                                 throws SQLException

Throws:

SQLException

removeLastValidState

protected void removeLastValidState()
                             throws SQLException

Throws:

SQLException