org.apache.ambari.server.upgrade

Class UpgradeCatalog270

java.lang.Object

org.apache.ambari.server.upgrade.AbstractUpgradeCatalog

org.apache.ambari.server.upgrade.UpgradeCatalog270

All Implemented Interfaces:

UpgradeCatalog

public class UpgradeCatalog270
extends AbstractUpgradeCatalog

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	ADMINPRIVILEGE_PERMISSION_ID_COLUMN
protected static String	ADMINPRIVILEGE_PRINCIPAL_ID_COLUMN
protected static String	ADMINPRIVILEGE_PRIVILEGE_ID_COLUMN
protected static String	ADMINPRIVILEGE_RESOURCE_ID_COLUMN
protected static String	ADMINPRIVILEGE_TABLE
protected static String	AMBARI_CONFIGURATION_CATEGORY_NAME_COLUMN
protected static String	AMBARI_CONFIGURATION_PROPERTY_NAME_COLUMN
protected static String	AMBARI_CONFIGURATION_PROPERTY_VALUE_COLUMN
protected static String	AMBARI_CONFIGURATION_TABLE
static String	AMBARI_INFRA_NEW_NAME
static String	AMBARI_INFRA_OLD_NAME
protected static String	AMBARI_SEQUENCES_SEQUENCE_NAME_COLUMN
protected static String	AMBARI_SEQUENCES_SEQUENCE_VALUE_COLUMN
protected static String	AMBARI_SEQUENCES_TABLE
static String	CLUSTER_CONFIG_TABLE
protected static String	COMPONENT_DESIRED_STATE_TABLE
protected static String	COMPONENT_LAST_STATE_COLUMN
protected static String	COMPONENT_NAME_COLUMN
protected static String	COMPONENT_STATE_TABLE
protected static String	CONFIGURATION_CORE_SITE
protected static String	CONFIGURATION_WEBHCAT_SITE
static String	FK_HOSTCOMPONENTDESIREDSTATE_COMPONENT_NAME
static String	FK_HOSTCOMPONENTSTATE_COMPONENT_NAME
protected static String	FK_KKP_HOST_ID
protected static String	FK_KKP_KEYTAB_PATH
protected static String	FK_KKP_PRINCIPAL_NAME
protected static String	FK_KKP_SERVICE_PRINCIPAL
static String	FK_SERVICECOMPONENTDESIREDSTATE_SERVICE_NAME
protected static String	GROUP_ACCESS_FIELD
protected static String	GROUP_NAME_FIELD
protected static String	HIVE_SERVICE_COMPONENT_WEBHCAT_SERVER
protected static String	HOST_ID_COLUMN
protected static String	HOST_ROLE_COMMAND_TABLE
protected static String	HOSTS_TABLE
protected static String	HRC_OPS_DISPLAY_NAME_COLUMN
protected static String	IS_AMBARI_KEYTAB_FIELD
protected static String	IS_DISTRIBUTED_COLUMN
protected static String	KERBEROS_KEYTAB_PRINCIPAL_TABLE
protected static String	KERBEROS_KEYTAB_TABLE
protected static String	KERBEROS_PRINCIPAL_HOST_TABLE
protected static String	KERBEROS_PRINCIPAL_TABLE
protected static String	KEYTAB_PATH_FIELD
protected static String	KKP_ID_COLUMN
protected static String	KKP_ID_SEQ_NAME
protected static String	KKP_MAPPING_SERVICE_TABLE
protected static String	MEMBERS_GROUP_ID_COLUMN
protected static String	MEMBERS_MEMBER_ID_COLUMN
protected static String	MEMBERS_TABLE
protected static String	MEMBERS_USER_ID_COLUMN
protected static String	OWNER_ACCESS_FIELD
protected static String	OWNER_NAME_FIELD
protected static String	PK_KERBEROS_KEYTAB
protected static String	PK_KKP
protected static String	PK_KKP_MAPPING_SERVICE
protected static String	PRINCIPAL_NAME_COLUMN
protected static String	PROPERTY_HADOOP_PROXYUSER_HTTP_HOSTS
protected static String	PROPERTY_TEMPLETON_HIVE_PROPERTIES
protected static String	REPO_APPLICABLE_SERVICES_FOREIGN_KEY
protected static String	REPO_APPLICABLE_SERVICES_REPO_DEFINITION_ID_COLUMN
protected static String	REPO_APPLICABLE_SERVICES_SERVICE_NAME_COLUMN
protected static String	REPO_APPLICABLE_SERVICES_TABLE
protected static String	REPO_DEFINITION_BASE_URL_COLUMN
protected static String	REPO_DEFINITION_COMPONENTS_COLUMN
protected static String	REPO_DEFINITION_DISTRIBUTION_COLUMN
protected static String	REPO_DEFINITION_FOREIGN_KEY
protected static String	REPO_DEFINITION_ID_COLUMN
protected static String	REPO_DEFINITION_MIRRORS_COLUMN
protected static String	REPO_DEFINITION_PRIMARY_KEY
protected static String	REPO_DEFINITION_REPO_ID_COLUMN
protected static String	REPO_DEFINITION_REPO_NAME_COLUMN
protected static String	REPO_DEFINITION_REPO_OS_ID_COLUMN
protected static String	REPO_DEFINITION_TABLE
protected static String	REPO_DEFINITION_UNIQUE_REPO_COLUMN
protected static String	REPO_OS_AMBARI_MANAGED_COLUMN
protected static String	REPO_OS_FAMILY_COLUMN
protected static String	REPO_OS_FOREIGN_KEY
protected static String	REPO_OS_ID_COLUMN
protected static String	REPO_OS_PRIMARY_KEY
protected static String	REPO_OS_REPO_VERSION_ID_COLUMN
protected static String	REPO_OS_TABLE
protected static String	REPO_TAGS_FOREIGN_KEY
protected static String	REPO_TAGS_REPO_DEFINITION_ID_COLUMN
protected static String	REPO_TAGS_TABLE
protected static String	REPO_TAGS_TAG_COLUMN
protected static String	REPO_VERSION_REPO_VERSION_ID_COLUMN
protected static String	REPO_VERSION_REPOSITORIES_COLUMN
protected static String	REPO_VERSION_TABLE
protected static String	REQUEST_DISPLAY_STATUS_COLUMN
protected static String	REQUEST_TABLE
protected static String	REQUEST_USER_NAME_COLUMN
protected static String	SECURITY_STATE_COLUMN
protected static String	SERVICE_COMPONENT_DESIRED_STATE_TABLE
static String	SERVICE_CONFIG_MAPPING_TABLE
protected static String	SERVICE_DESIRED_STATE_TABLE
protected static String	SERVICE_NAME_COLUMN
protected static String	STAGE_DISPLAY_STATUS_COLUMN
protected static String	STAGE_STATUS_COLUMN
protected static String	STAGE_TABLE
protected static String	UNI_KKP
protected static String	UNIQUE_USERS_0_INDEX
protected static String	USER_AUTHENTICATION_AUTHENTICATION_KEY_COLUMN
protected static String	USER_AUTHENTICATION_AUTHENTICATION_TYPE_COLUMN
protected static String	USER_AUTHENTICATION_CREATE_TIME_COLUMN
protected static String	USER_AUTHENTICATION_PRIMARY_KEY
protected static String	USER_AUTHENTICATION_TABLE
protected static String	USER_AUTHENTICATION_UPDATE_TIME_COLUMN
protected static String	USER_AUTHENTICATION_USER_AUTHENTICATION_ID_COLUMN
protected static String	USER_AUTHENTICATION_USER_AUTHENTICATION_USER_ID_INDEX
protected static String	USER_AUTHENTICATION_USER_AUTHENTICATION_USERS_FOREIGN_KEY
protected static String	USER_AUTHENTICATION_USER_ID_COLUMN
protected static String	USERS_CONSECUTIVE_FAILURES_COLUMN
protected static String	USERS_CREATE_TIME_COLUMN
protected static String	USERS_DISPLAY_NAME_COLUMN
protected static String	USERS_LDAP_USER_COLUMN
protected static String	USERS_LOCAL_USERNAME_COLUMN
protected static String	USERS_PRINCIPAL_ID_COLUMN
protected static String	USERS_TABLE
protected static String	USERS_USER_ID_COLUMN
protected static String	USERS_USER_NAME_COLUMN
protected static String	USERS_USER_PASSWORD_COLUMN
protected static String	USERS_USER_TYPE_COLUMN
protected static String	USERS_VERSION_COLUMN
protected static String	WIDGET_TABLE
protected static String	WIDGET_TAG_COLUMN
protected static String	WRITE_AMBARI_JAAS_FIELD

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
UpgradeCatalog270(com.google.inject.Injector injector) Don't forget to register new UpgradeCatalogs in SchemaUpgradeHelper.UpgradeHelperModule.configure()

Method Summary

Modifier and Type	Method and Description
protected void	addAmbariConfigurationTable()
protected void	addHostComponentLastStateTable()
protected void	addUserAuthenticationSequence()
protected void	clearHadoopMetrics2Content()
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
protected PrepareKerberosIdentitiesServerAction	getPrepareIdentityServerAction()
String	getSourceVersion() Return latest source version that can be upgraded from.
String	getTargetVersion() Return the version that will be upgraded to
protected void	moveAmbariPropertiesToAmbariConfiguration() Moves SSO and LDAP related properties from ambari.properties to ambari_configuration DB table
protected String	removeAdminHandlers(String content)
protected void	renameAmbariInfra()
protected void	setStatusOfStagesAndRequests()
protected void	showHcatDeletedUserMessage()
protected void	updateAmsConfigs()
protected String	updateInfraSolrEnv(String content)
protected void	updateKerberosConfigurations() Upgrades kerberos related data.
protected void	updateKerberosDescriptorArtifact(ArtifactDAO artifactDAO, ArtifactEntity artifactEntity) Update the specified Kerberos Descriptor artifact to conform to the new structure.
protected void	updateLogSearchConfigs() Updates Log Search configs.
protected String	updateLuceneMatchVersion(String content, String newLuceneMatchVersion)
protected String	updateMergeFactor(String content, String variableName)
protected void	updateRequestTable()
protected void	updateSolrConfigurations()
protected void	updateStageTable()
protected void	updateStormConfigs() Removes storm-site configs that were present for ambari needs and sets the actual property `storm.thrift.transport` to the correct value
protected void	upgradeKerberosTables() Creates new tables for changed kerberos data.
protected void	upgradeRepoTables()
protected void	upgradeUserTables() Upgrade the users table as well as supporting tables.
protected void	upgradeWidgetTable()

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

Field Detail

STAGE_TABLE

protected static final String STAGE_TABLE

See Also:

Constant Field Values

STAGE_STATUS_COLUMN

protected static final String STAGE_STATUS_COLUMN

See Also:

Constant Field Values

STAGE_DISPLAY_STATUS_COLUMN

protected static final String STAGE_DISPLAY_STATUS_COLUMN

See Also:

Constant Field Values

REQUEST_TABLE

protected static final String REQUEST_TABLE

See Also:

Constant Field Values

REQUEST_DISPLAY_STATUS_COLUMN

protected static final String REQUEST_DISPLAY_STATUS_COLUMN

See Also:

Constant Field Values

REQUEST_USER_NAME_COLUMN

protected static final String REQUEST_USER_NAME_COLUMN

See Also:

Constant Field Values

HOST_ROLE_COMMAND_TABLE

protected static final String HOST_ROLE_COMMAND_TABLE

See Also:

Constant Field Values

HRC_OPS_DISPLAY_NAME_COLUMN

protected static final String HRC_OPS_DISPLAY_NAME_COLUMN

See Also:

Constant Field Values

COMPONENT_DESIRED_STATE_TABLE

protected static final String COMPONENT_DESIRED_STATE_TABLE

See Also:

Constant Field Values

COMPONENT_STATE_TABLE

protected static final String COMPONENT_STATE_TABLE

See Also:

Constant Field Values

COMPONENT_LAST_STATE_COLUMN

protected static final String COMPONENT_LAST_STATE_COLUMN

See Also:

Constant Field Values

SERVICE_DESIRED_STATE_TABLE

protected static final String SERVICE_DESIRED_STATE_TABLE

See Also:

Constant Field Values

SECURITY_STATE_COLUMN

protected static final String SECURITY_STATE_COLUMN

See Also:

Constant Field Values

AMBARI_SEQUENCES_TABLE

protected static final String AMBARI_SEQUENCES_TABLE

See Also:

Constant Field Values

AMBARI_SEQUENCES_SEQUENCE_NAME_COLUMN

protected static final String AMBARI_SEQUENCES_SEQUENCE_NAME_COLUMN

See Also:

Constant Field Values

AMBARI_SEQUENCES_SEQUENCE_VALUE_COLUMN

protected static final String AMBARI_SEQUENCES_SEQUENCE_VALUE_COLUMN

See Also:

Constant Field Values

AMBARI_CONFIGURATION_TABLE

protected static final String AMBARI_CONFIGURATION_TABLE

See Also:

Constant Field Values

AMBARI_CONFIGURATION_CATEGORY_NAME_COLUMN

protected static final String AMBARI_CONFIGURATION_CATEGORY_NAME_COLUMN

See Also:

Constant Field Values

AMBARI_CONFIGURATION_PROPERTY_NAME_COLUMN

protected static final String AMBARI_CONFIGURATION_PROPERTY_NAME_COLUMN

See Also:

Constant Field Values

AMBARI_CONFIGURATION_PROPERTY_VALUE_COLUMN

protected static final String AMBARI_CONFIGURATION_PROPERTY_VALUE_COLUMN

See Also:

Constant Field Values

USER_AUTHENTICATION_TABLE

protected static final String USER_AUTHENTICATION_TABLE

See Also:

Constant Field Values

USER_AUTHENTICATION_USER_AUTHENTICATION_ID_COLUMN

protected static final String USER_AUTHENTICATION_USER_AUTHENTICATION_ID_COLUMN

See Also:

Constant Field Values

USER_AUTHENTICATION_USER_ID_COLUMN

protected static final String USER_AUTHENTICATION_USER_ID_COLUMN

See Also:

Constant Field Values

USER_AUTHENTICATION_AUTHENTICATION_TYPE_COLUMN

protected static final String USER_AUTHENTICATION_AUTHENTICATION_TYPE_COLUMN

See Also:

Constant Field Values

USER_AUTHENTICATION_AUTHENTICATION_KEY_COLUMN

protected static final String USER_AUTHENTICATION_AUTHENTICATION_KEY_COLUMN

See Also:

Constant Field Values

USER_AUTHENTICATION_CREATE_TIME_COLUMN

protected static final String USER_AUTHENTICATION_CREATE_TIME_COLUMN

See Also:

Constant Field Values

USER_AUTHENTICATION_UPDATE_TIME_COLUMN

protected static final String USER_AUTHENTICATION_UPDATE_TIME_COLUMN

See Also:

Constant Field Values

USER_AUTHENTICATION_PRIMARY_KEY

protected static final String USER_AUTHENTICATION_PRIMARY_KEY

See Also:

Constant Field Values

USER_AUTHENTICATION_USER_AUTHENTICATION_USER_ID_INDEX

protected static final String USER_AUTHENTICATION_USER_AUTHENTICATION_USER_ID_INDEX

See Also:

Constant Field Values

USER_AUTHENTICATION_USER_AUTHENTICATION_USERS_FOREIGN_KEY

protected static final String USER_AUTHENTICATION_USER_AUTHENTICATION_USERS_FOREIGN_KEY

See Also:

Constant Field Values

USERS_TABLE

protected static final String USERS_TABLE

See Also:

Constant Field Values

USERS_USER_ID_COLUMN

protected static final String USERS_USER_ID_COLUMN

See Also:

Constant Field Values

USERS_PRINCIPAL_ID_COLUMN

protected static final String USERS_PRINCIPAL_ID_COLUMN

See Also:

Constant Field Values

USERS_USER_TYPE_COLUMN

protected static final String USERS_USER_TYPE_COLUMN

See Also:

Constant Field Values

USERS_USER_PASSWORD_COLUMN

protected static final String USERS_USER_PASSWORD_COLUMN

See Also:

Constant Field Values

USERS_CREATE_TIME_COLUMN

protected static final String USERS_CREATE_TIME_COLUMN

See Also:

Constant Field Values

USERS_LDAP_USER_COLUMN

protected static final String USERS_LDAP_USER_COLUMN

See Also:

Constant Field Values

USERS_CONSECUTIVE_FAILURES_COLUMN

protected static final String USERS_CONSECUTIVE_FAILURES_COLUMN

See Also:

Constant Field Values

USERS_USER_NAME_COLUMN

protected static final String USERS_USER_NAME_COLUMN

See Also:

Constant Field Values

USERS_DISPLAY_NAME_COLUMN

protected static final String USERS_DISPLAY_NAME_COLUMN

See Also:

Constant Field Values

USERS_LOCAL_USERNAME_COLUMN

protected static final String USERS_LOCAL_USERNAME_COLUMN

See Also:

Constant Field Values

USERS_VERSION_COLUMN

protected static final String USERS_VERSION_COLUMN

See Also:

Constant Field Values

UNIQUE_USERS_0_INDEX

protected static final String UNIQUE_USERS_0_INDEX

See Also:

Constant Field Values

MEMBERS_TABLE

protected static final String MEMBERS_TABLE

See Also:

Constant Field Values

MEMBERS_MEMBER_ID_COLUMN

protected static final String MEMBERS_MEMBER_ID_COLUMN

See Also:

Constant Field Values

MEMBERS_GROUP_ID_COLUMN

protected static final String MEMBERS_GROUP_ID_COLUMN

See Also:

Constant Field Values

MEMBERS_USER_ID_COLUMN

protected static final String MEMBERS_USER_ID_COLUMN

See Also:

Constant Field Values

ADMINPRIVILEGE_TABLE

protected static final String ADMINPRIVILEGE_TABLE

See Also:

Constant Field Values

ADMINPRIVILEGE_PRIVILEGE_ID_COLUMN

protected static final String ADMINPRIVILEGE_PRIVILEGE_ID_COLUMN

See Also:

Constant Field Values

ADMINPRIVILEGE_PERMISSION_ID_COLUMN

protected static final String ADMINPRIVILEGE_PERMISSION_ID_COLUMN

See Also:

Constant Field Values

ADMINPRIVILEGE_RESOURCE_ID_COLUMN

protected static final String ADMINPRIVILEGE_RESOURCE_ID_COLUMN

See Also:

Constant Field Values

ADMINPRIVILEGE_PRINCIPAL_ID_COLUMN

protected static final String ADMINPRIVILEGE_PRINCIPAL_ID_COLUMN

See Also:

Constant Field Values

KERBEROS_KEYTAB_TABLE

protected static final String KERBEROS_KEYTAB_TABLE

See Also:

Constant Field Values

KERBEROS_KEYTAB_PRINCIPAL_TABLE

protected static final String KERBEROS_KEYTAB_PRINCIPAL_TABLE

See Also:

Constant Field Values

KKP_MAPPING_SERVICE_TABLE

protected static final String KKP_MAPPING_SERVICE_TABLE

See Also:

Constant Field Values

KEYTAB_PATH_FIELD

protected static final String KEYTAB_PATH_FIELD

See Also:

Constant Field Values

OWNER_NAME_FIELD

protected static final String OWNER_NAME_FIELD

See Also:

Constant Field Values

OWNER_ACCESS_FIELD

protected static final String OWNER_ACCESS_FIELD

See Also:

Constant Field Values

GROUP_NAME_FIELD

protected static final String GROUP_NAME_FIELD

See Also:

Constant Field Values

GROUP_ACCESS_FIELD

protected static final String GROUP_ACCESS_FIELD

See Also:

Constant Field Values

IS_AMBARI_KEYTAB_FIELD

protected static final String IS_AMBARI_KEYTAB_FIELD

See Also:

Constant Field Values

WRITE_AMBARI_JAAS_FIELD

protected static final String WRITE_AMBARI_JAAS_FIELD

See Also:

Constant Field Values

PK_KERBEROS_KEYTAB

protected static final String PK_KERBEROS_KEYTAB

See Also:

Constant Field Values

KKP_ID_COLUMN

protected static final String KKP_ID_COLUMN

See Also:

Constant Field Values

PRINCIPAL_NAME_COLUMN

protected static final String PRINCIPAL_NAME_COLUMN

See Also:

Constant Field Values

IS_DISTRIBUTED_COLUMN

protected static final String IS_DISTRIBUTED_COLUMN

See Also:

Constant Field Values

PK_KKP

protected static final String PK_KKP

See Also:

Constant Field Values

UNI_KKP

protected static final String UNI_KKP

See Also:

Constant Field Values

SERVICE_NAME_COLUMN

protected static final String SERVICE_NAME_COLUMN

See Also:

Constant Field Values

COMPONENT_NAME_COLUMN

protected static final String COMPONENT_NAME_COLUMN

See Also:

Constant Field Values

PK_KKP_MAPPING_SERVICE

protected static final String PK_KKP_MAPPING_SERVICE

See Also:

Constant Field Values

FK_KKP_KEYTAB_PATH

protected static final String FK_KKP_KEYTAB_PATH

See Also:

Constant Field Values

FK_KKP_HOST_ID

protected static final String FK_KKP_HOST_ID

See Also:

Constant Field Values

FK_KKP_PRINCIPAL_NAME

protected static final String FK_KKP_PRINCIPAL_NAME

See Also:

Constant Field Values

HOSTS_TABLE

protected static final String HOSTS_TABLE

See Also:

Constant Field Values

KERBEROS_PRINCIPAL_TABLE

protected static final String KERBEROS_PRINCIPAL_TABLE

See Also:

Constant Field Values

FK_KKP_SERVICE_PRINCIPAL

protected static final String FK_KKP_SERVICE_PRINCIPAL

See Also:

Constant Field Values

KKP_ID_SEQ_NAME

protected static final String KKP_ID_SEQ_NAME

See Also:

Constant Field Values

KERBEROS_PRINCIPAL_HOST_TABLE

protected static final String KERBEROS_PRINCIPAL_HOST_TABLE

See Also:

Constant Field Values

HOST_ID_COLUMN

protected static final String HOST_ID_COLUMN

See Also:

Constant Field Values

REPO_OS_TABLE

protected static final String REPO_OS_TABLE

See Also:

Constant Field Values

REPO_OS_ID_COLUMN

protected static final String REPO_OS_ID_COLUMN

See Also:

Constant Field Values

REPO_OS_REPO_VERSION_ID_COLUMN

protected static final String REPO_OS_REPO_VERSION_ID_COLUMN

See Also:

Constant Field Values

REPO_OS_FAMILY_COLUMN

protected static final String REPO_OS_FAMILY_COLUMN

See Also:

Constant Field Values

REPO_OS_AMBARI_MANAGED_COLUMN

protected static final String REPO_OS_AMBARI_MANAGED_COLUMN

See Also:

Constant Field Values

REPO_OS_PRIMARY_KEY

protected static final String REPO_OS_PRIMARY_KEY

See Also:

Constant Field Values

REPO_OS_FOREIGN_KEY

protected static final String REPO_OS_FOREIGN_KEY

See Also:

Constant Field Values

REPO_DEFINITION_TABLE

protected static final String REPO_DEFINITION_TABLE

See Also:

Constant Field Values

REPO_DEFINITION_ID_COLUMN

protected static final String REPO_DEFINITION_ID_COLUMN

See Also:

Constant Field Values

REPO_DEFINITION_REPO_OS_ID_COLUMN

protected static final String REPO_DEFINITION_REPO_OS_ID_COLUMN

See Also:

Constant Field Values

REPO_DEFINITION_REPO_NAME_COLUMN

protected static final String REPO_DEFINITION_REPO_NAME_COLUMN

See Also:

Constant Field Values

REPO_DEFINITION_REPO_ID_COLUMN

protected static final String REPO_DEFINITION_REPO_ID_COLUMN

See Also:

Constant Field Values

REPO_DEFINITION_BASE_URL_COLUMN

protected static final String REPO_DEFINITION_BASE_URL_COLUMN

See Also:

Constant Field Values

REPO_DEFINITION_DISTRIBUTION_COLUMN

protected static final String REPO_DEFINITION_DISTRIBUTION_COLUMN

See Also:

Constant Field Values

REPO_DEFINITION_COMPONENTS_COLUMN

protected static final String REPO_DEFINITION_COMPONENTS_COLUMN

See Also:

Constant Field Values

REPO_DEFINITION_UNIQUE_REPO_COLUMN

protected static final String REPO_DEFINITION_UNIQUE_REPO_COLUMN

See Also:

Constant Field Values

REPO_DEFINITION_MIRRORS_COLUMN

protected static final String REPO_DEFINITION_MIRRORS_COLUMN

See Also:

Constant Field Values

REPO_DEFINITION_PRIMARY_KEY

protected static final String REPO_DEFINITION_PRIMARY_KEY

See Also:

Constant Field Values

REPO_DEFINITION_FOREIGN_KEY

protected static final String REPO_DEFINITION_FOREIGN_KEY

See Also:

Constant Field Values

REPO_TAGS_TABLE

protected static final String REPO_TAGS_TABLE

See Also:

Constant Field Values

REPO_TAGS_REPO_DEFINITION_ID_COLUMN

protected static final String REPO_TAGS_REPO_DEFINITION_ID_COLUMN

See Also:

Constant Field Values

REPO_TAGS_TAG_COLUMN

protected static final String REPO_TAGS_TAG_COLUMN

See Also:

Constant Field Values

REPO_TAGS_FOREIGN_KEY

protected static final String REPO_TAGS_FOREIGN_KEY

See Also:

Constant Field Values

REPO_APPLICABLE_SERVICES_TABLE

protected static final String REPO_APPLICABLE_SERVICES_TABLE

See Also:

Constant Field Values

REPO_APPLICABLE_SERVICES_REPO_DEFINITION_ID_COLUMN

protected static final String REPO_APPLICABLE_SERVICES_REPO_DEFINITION_ID_COLUMN

See Also:

Constant Field Values

REPO_APPLICABLE_SERVICES_SERVICE_NAME_COLUMN

protected static final String REPO_APPLICABLE_SERVICES_SERVICE_NAME_COLUMN

See Also:

Constant Field Values

REPO_APPLICABLE_SERVICES_FOREIGN_KEY

protected static final String REPO_APPLICABLE_SERVICES_FOREIGN_KEY

See Also:

Constant Field Values

REPO_VERSION_TABLE

protected static final String REPO_VERSION_TABLE

See Also:

Constant Field Values

REPO_VERSION_REPO_VERSION_ID_COLUMN

protected static final String REPO_VERSION_REPO_VERSION_ID_COLUMN

See Also:

Constant Field Values

REPO_VERSION_REPOSITORIES_COLUMN

protected static final String REPO_VERSION_REPOSITORIES_COLUMN

See Also:

Constant Field Values

WIDGET_TABLE

protected static final String WIDGET_TABLE

See Also:

Constant Field Values

WIDGET_TAG_COLUMN

protected static final String WIDGET_TAG_COLUMN

See Also:

Constant Field Values

SERVICE_COMPONENT_DESIRED_STATE_TABLE

protected static final String SERVICE_COMPONENT_DESIRED_STATE_TABLE

See Also:

Constant Field Values

HIVE_SERVICE_COMPONENT_WEBHCAT_SERVER

protected static final String HIVE_SERVICE_COMPONENT_WEBHCAT_SERVER

See Also:

Constant Field Values

CONFIGURATION_CORE_SITE

protected static final String CONFIGURATION_CORE_SITE

See Also:

Constant Field Values

CONFIGURATION_WEBHCAT_SITE

protected static final String CONFIGURATION_WEBHCAT_SITE

See Also:

Constant Field Values

PROPERTY_HADOOP_PROXYUSER_HTTP_HOSTS

protected static final String PROPERTY_HADOOP_PROXYUSER_HTTP_HOSTS

See Also:

Constant Field Values

PROPERTY_TEMPLETON_HIVE_PROPERTIES

protected static final String PROPERTY_TEMPLETON_HIVE_PROPERTIES

See Also:

Constant Field Values

AMBARI_INFRA_OLD_NAME

public static final String AMBARI_INFRA_OLD_NAME

See Also:

Constant Field Values

AMBARI_INFRA_NEW_NAME

public static final String AMBARI_INFRA_NEW_NAME

See Also:

Constant Field Values

SERVICE_CONFIG_MAPPING_TABLE

public static final String SERVICE_CONFIG_MAPPING_TABLE

See Also:

Constant Field Values

CLUSTER_CONFIG_TABLE

public static final String CLUSTER_CONFIG_TABLE

See Also:

Constant Field Values

FK_HOSTCOMPONENTDESIREDSTATE_COMPONENT_NAME

public static final String FK_HOSTCOMPONENTDESIREDSTATE_COMPONENT_NAME

See Also:

Constant Field Values

FK_HOSTCOMPONENTSTATE_COMPONENT_NAME

public static final String FK_HOSTCOMPONENTSTATE_COMPONENT_NAME

See Also:

Constant Field Values

FK_SERVICECOMPONENTDESIREDSTATE_SERVICE_NAME

public static final String FK_SERVICECOMPONENTDESIREDSTATE_SERVICE_NAME

See Also:

Constant Field Values

Constructor Detail

UpgradeCatalog270

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

Don't forget to register new UpgradeCatalogs in SchemaUpgradeHelper.UpgradeHelperModule.configure()

Parameters:

injector - Guice injector to track dependencies and uses bindings to inject them.

Method Detail

getTargetVersion

public String getTargetVersion()

Return the version that will be upgraded to

Returns:

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

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

upgradeUserTables

protected void upgradeUserTables()
                          throws SQLException

Upgrade the users table as well as supporting tables.

Affected table are

• users
• user_authentication (new)
• members
• adminprivilege

Throws:

SQLException - if an error occurs while executing SQL statements

See Also:

createUserAuthenticationTable(), updateGroupMembershipRecords(), updateAdminPrivilegeRecords(), updateUsersTable()

upgradeRepoTables

protected void upgradeRepoTables()
                          throws SQLException

Throws:

SQLException

updateStageTable

protected void updateStageTable()
                         throws SQLException

Throws:

SQLException

updateRequestTable

protected void updateRequestTable()
                           throws SQLException

Throws:

SQLException

upgradeWidgetTable

protected void upgradeWidgetTable()
                           throws SQLException

Throws:

SQLException

addAmbariConfigurationTable

protected void addAmbariConfigurationTable()
                                    throws SQLException

Throws:

SQLException

addHostComponentLastStateTable

protected void addHostComponentLastStateTable()
                                       throws SQLException

Throws:

SQLException

upgradeKerberosTables

protected void upgradeKerberosTables()
                              throws SQLException

Creates new tables for changed kerberos data.

Throws:

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

renameAmbariInfra

protected void renameAmbariInfra()

updateKerberosDescriptorArtifact

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

Description copied from class: AbstractUpgradeCatalog

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

addUserAuthenticationSequence

protected void addUserAuthenticationSequence()
                                      throws SQLException

Throws:

SQLException

createRoleAuthorizations

protected void createRoleAuthorizations()
                                 throws SQLException

Throws:

SQLException

showHcatDeletedUserMessage

protected void showHcatDeletedUserMessage()

setStatusOfStagesAndRequests

protected void setStatusOfStagesAndRequests()

updateLogSearchConfigs

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

Updates Log Search configs.

Throws:

org.apache.ambari.server.AmbariException

SQLException

removeAdminHandlers

protected String removeAdminHandlers(String content)

getPrepareIdentityServerAction

protected PrepareKerberosIdentitiesServerAction getPrepareIdentityServerAction()

updateKerberosConfigurations

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

Upgrades kerberos related data. Also creates keytabs and principals database records. This happens via code in PrepareKerberosIdentitiesServerAction, so code reused and all changes will be reflected in upgrade.

Throws:

org.apache.ambari.server.AmbariException

moveAmbariPropertiesToAmbariConfiguration

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

Moves SSO and LDAP related properties from ambari.properties to ambari_configuration DB table

Throws:

org.apache.ambari.server.AmbariException - if there was any issue when clearing ambari.properties

updateSolrConfigurations

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

Throws:

org.apache.ambari.server.AmbariException

updateLuceneMatchVersion

protected String updateLuceneMatchVersion(String content,
                                          String newLuceneMatchVersion)

updateMergeFactor

protected String updateMergeFactor(String content,
                                   String variableName)

updateInfraSolrEnv

protected String updateInfraSolrEnv(String content)

updateAmsConfigs

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

Throws:

org.apache.ambari.server.AmbariException

updateStormConfigs

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

Removes storm-site configs that were present for ambari needs and sets the actual property `storm.thrift.transport` to the correct value

Throws:

org.apache.ambari.server.AmbariException

clearHadoopMetrics2Content

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

Throws:

org.apache.ambari.server.AmbariException