org.apache.ambari.server.stack.upgrade

Class RepositoryVersionHelper

java.lang.Object

org.apache.ambari.server.stack.upgrade.RepositoryVersionHelper

public class RepositoryVersionHelper
extends Object

Provides helper methods to manage repository versions.

Constructor Summary

Constructors

Constructor and Description
RepositoryVersionHelper()

Method Summary

Modifier and Type	Method and Description
void	addCommandRepositoryToContext(ActionExecutionContext context, RepositoryVersionEntity repoVersion, RepoOsEntity osEntity) Adds a command repository to the action context
void	addRepoInfoToHostLevelParams(Cluster cluster, ActionExecutionContext actionContext, RepositoryVersionEntity repositoryVersion, Map<String,String> hostLevelParams, String hostName) Deprecated.
Map<String,String>	buildRoleParams(AmbariManagementController amc, RepositoryVersionEntity repoVersion, String osFamily, Set<String> servicesOnHost) Build the role parameters for an install command.
List<RepoOsEntity>	createRepoOsEntities(List<RepositoryInfo> repositories)
CommandRepository	getCommandRepository(Cluster cluster, ServiceComponent component, Host host) Builds repository information for inclusion in a command.
CommandRepository	getCommandRepository(Cluster cluster, Service service, Host host, String componentName)
CommandRepository	getCommandRepository(RepositoryVersionEntity repoVersion, RepoOsEntity osEntity) Adds a command repository to the action context
RepoOsEntity	getOSEntityForHost(Host host, RepositoryVersionEntity repoVersion) Return repositories available for target os version on host based on repoVersion repository definition
String	getRepoInfo(Cluster cluster, ServiceComponent component, Host host) Deprecated. use getCommandRepository(Cluster, ServiceComponent, Host) instead.
String	getRepoInfoString(Cluster cluster, ServiceComponent component, Host host) Get repository info given a cluster and host.
String	getUpgradePackageName(String stackName, String stackVersion, String repositoryVersion, org.apache.ambari.spi.upgrade.UpgradeType upgradeType) Scans the given stack for upgrade packages which can be applied to update the cluster to given repository version.
List<RepoOsEntity>	parseOperatingSystems(String repositoriesJson) Parses operating systems json to a list of entities.

Methods inherited from class java.lang.Object

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

Constructor Detail

RepositoryVersionHelper

public RepositoryVersionHelper()

Method Detail

parseOperatingSystems

public List<RepoOsEntity> parseOperatingSystems(String repositoriesJson)
                                         throws Exception

Parses operating systems json to a list of entities. Expects json like:

 [
    {
       "repositories":[
          {
             "Repositories/base_url":"http://s3.amazonaws.com/dev.hortonworks.com/HDP/centos6/2.x/updates/2.2.0.0",
             "Repositories/repo_name":"HDP-UTILS",
             "Repositories/repo_id":"HDP-UTILS-1.1.0.20"
          },
          {
             "Repositories/base_url":"http://s3.amazonaws.com/dev.hortonworks.com/HDP/centos6/2.x/updates/2.2.0.0",
             "Repositories/repo_name":"HDP",
             "Repositories/repo_id":"HDP-2.2"
          }
       ],
       "OperatingSystems/os_type":"redhat6"
    }
 ]
 

Parameters:

repositoriesJson - operating systems json

Returns:

list of operating system entities

Throws:

Exception - if any kind of json parsing error happened

createRepoOsEntities

public List<RepoOsEntity> createRepoOsEntities(List<RepositoryInfo> repositories)

getUpgradePackageName

public String getUpgradePackageName(String stackName,
                                    String stackVersion,
                                    String repositoryVersion,
                                    org.apache.ambari.spi.upgrade.UpgradeType upgradeType)
                             throws org.apache.ambari.server.AmbariException

Scans the given stack for upgrade packages which can be applied to update the cluster to given repository version.

Parameters:

stackName - stack name

stackVersion - stack version

repositoryVersion - target repository version

upgradeType - if not null null, will only return upgrade packs whose type matches.

Returns:

upgrade pack name

Throws:

org.apache.ambari.server.AmbariException - if no upgrade packs suit the requirements

buildRoleParams

public Map<String,String> buildRoleParams(AmbariManagementController amc,
                                          RepositoryVersionEntity repoVersion,
                                          String osFamily,
                                          Set<String> servicesOnHost)
                                   throws SystemException

Build the role parameters for an install command.

Parameters:

amc - the management controller. Tests don't use the same instance that gets injected.

repoVersion - the repository version

osFamily - the os family

servicesOnHost - the set of services to check for packages

Returns:

a Map to use in

Throws:

SystemException

getOSEntityForHost

public RepoOsEntity getOSEntityForHost(Host host,
                                       RepositoryVersionEntity repoVersion)
                                throws SystemException

Return repositories available for target os version on host based on repoVersion repository definition

Parameters:

host - target Host for providing repositories list

repoVersion - RepositoryVersionEntity version definition with all available repositories

Returns:

RepoOsEntity with available repositories for host

Throws:

SystemException - if no repository available for target Host

getCommandRepository

public CommandRepository getCommandRepository(RepositoryVersionEntity repoVersion,
                                              RepoOsEntity osEntity)
                                       throws SystemException

Adds a command repository to the action context

Parameters:

osEntity - the OS family

Throws:

SystemException

getCommandRepository

public CommandRepository getCommandRepository(Cluster cluster,
                                              ServiceComponent component,
                                              Host host)
                                       throws SystemException

Builds repository information for inclusion in a command. This replaces escaping json on a command.

Parameters:

cluster - the cluster

host - the host

component - ServiceComponent object, could be null to return service-related repository

Returns:

the command repository

Throws:

SystemException

getCommandRepository

public CommandRepository getCommandRepository(Cluster cluster,
                                              Service service,
                                              Host host,
                                              String componentName)
                                       throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

addRepoInfoToHostLevelParams

@Deprecated
public void addRepoInfoToHostLevelParams(Cluster cluster,
                                                     ActionExecutionContext actionContext,
                                                     RepositoryVersionEntity repositoryVersion,
                                                     Map<String,String> hostLevelParams,
                                                     String hostName)
                                              throws org.apache.ambari.server.AmbariException

Deprecated.

This method builds and adds repo infoto hostLevelParams of action

Parameters:

cluster - cluster to which host level params belongs

actionContext - context of the action. Must be not null

repositoryVersion - repository version entity to use

hostLevelParams - hasgmap with host level params. Must be not null

hostName - host name to which add repo onfo

Throws:

org.apache.ambari.server.AmbariException

getRepoInfo

@Deprecated
public String getRepoInfo(Cluster cluster,
                                      ServiceComponent component,
                                      Host host)
                               throws SystemException

Deprecated. use getCommandRepository(Cluster, ServiceComponent, Host) instead.

Get repository info given a cluster and host.

Parameters:

cluster - the cluster

host - the host

Returns:

the repo info

Throws:

SystemException - if the repository information can not be obtained

addCommandRepositoryToContext

public void addCommandRepositoryToContext(ActionExecutionContext context,
                                          RepositoryVersionEntity repoVersion,
                                          RepoOsEntity osEntity)
                                   throws SystemException

Adds a command repository to the action context

Parameters:

context - the context

osEntity - the OS family

Throws:

SystemException

getRepoInfoString

public String getRepoInfoString(Cluster cluster,
                                ServiceComponent component,
                                Host host)
                         throws org.apache.ambari.server.AmbariException,
                                SystemException

Get repository info given a cluster and host.

Parameters:

cluster - the cluster

host - the host

Returns:

the repo info

Throws:

org.apache.ambari.server.AmbariException - if the repository information can not be obtained

SystemException