org.apache.ambari.server.stack

Class StackManager

java.lang.Object

org.apache.ambari.server.stack.StackManager

public class StackManager
extends Object

Manages all stack related behavior including parsing of stacks and providing access to stack information.

Field Summary

Fields

Modifier and Type	Field and Description
static String	COMMON_SERVICES Prefix used for common services parent path string
protected Map<String,ServiceModule>	commonServiceModules
protected Map<String,ExtensionModule>	extensionModules
static String	EXTENSIONS Prefix used for extension services parent path string
static String	METAINFO_FILE_NAME
static String	PATH_DELIMITER Delimiter used for parent path string Example: HDP/2.0.6/HDFS common-services/HDFS/2.1.0.2.0
static String	PROPERTY_SCHEMA_PATH
protected NavigableMap<String,StackInfo>	stackMap Map of stack id to stack info
protected Map<String,StackModule>	stackModules

Constructor Summary

Constructors

Constructor and Description
StackManager(File stackRoot, File commonServicesRoot, File extensionRoot, OsFamily osFamily, boolean validate, MetainfoDAO metaInfoDAO, ActionMetadata actionMetadata, StackDAO stackDao, ExtensionDAO extensionDao, ExtensionLinkDAO linkDao, AmbariManagementHelper helper) Constructor.

Method Summary

Modifier and Type	Method and Description
ExtensionInfo	getExtension(String name, String version) Obtain the extension info specified by name and version.
Collection<ExtensionInfo>	getExtensions() Obtain all extensions.
Collection<ExtensionInfo>	getExtensions(String name) Obtain all extensions for the given name.
static Validator	getPropertySchemaValidator()
StackInfo	getStack(String name, String version) Obtain the stack info specified by name and version.
Collection<StackInfo>	getStacks() Obtain all stacks.
Collection<StackInfo>	getStacks(String name) Obtain all stacks for the given name.
Map<String,List<StackInfo>>	getStacksByName() Obtain all a map of all stacks by name.
boolean	haveAllRepoUrlsBeenResolved() Determine if all tasks which update stack repo urls have completed.
void	linkStackToExtension(StackInfo stack, ExtensionInfo extension)
protected void	parseDirectories(File stackRoot, File commonServicesRoot, File extensionRoot)
void	removeStack(StackEntity stackEntity)
void	unlinkStackAndExtension(StackInfo stack, ExtensionInfo extension)
static void	validateAllPropertyXmlsInFolderRecursively(File stackRoot, Validator validator)

Methods inherited from class java.lang.Object

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

Field Detail

PROPERTY_SCHEMA_PATH

public static final String PROPERTY_SCHEMA_PATH

See Also:

Constant Field Values

PATH_DELIMITER

public static final String PATH_DELIMITER

Delimiter used for parent path string Example: HDP/2.0.6/HDFS common-services/HDFS/2.1.0.2.0

See Also:

Constant Field Values

COMMON_SERVICES

public static final String COMMON_SERVICES

Prefix used for common services parent path string

See Also:

Constant Field Values

EXTENSIONS

public static final String EXTENSIONS

Prefix used for extension services parent path string

See Also:

Constant Field Values

METAINFO_FILE_NAME

public static final String METAINFO_FILE_NAME

See Also:

Constant Field Values

stackMap

protected NavigableMap<String,StackInfo> stackMap

Map of stack id to stack info

commonServiceModules

protected Map<String,ServiceModule> commonServiceModules

stackModules

protected Map<String,StackModule> stackModules

extensionModules

protected Map<String,ExtensionModule> extensionModules

Constructor Detail

StackManager

public StackManager(File stackRoot,
                    @Nullable
                    File commonServicesRoot,
                    @Nullable
                    File extensionRoot,
                    OsFamily osFamily,
                    boolean validate,
                    MetainfoDAO metaInfoDAO,
                    ActionMetadata actionMetadata,
                    StackDAO stackDao,
                    ExtensionDAO extensionDao,
                    ExtensionLinkDAO linkDao,
                    AmbariManagementHelper helper)
             throws org.apache.ambari.server.AmbariException

Constructor. Initialize stack manager.

Parameters:

stackRootDir - stack root directory

commonServicesRoot - common services root directory

extensionRoot - extensions root directory

osFamily - the OS family read from resources

metaInfoDAO - metainfo DAO automatically injected

actionMetadata - action meta data automatically injected

stackDao - stack DAO automatically injected

extensionDao - extension DAO automatically injected

linkDao - extension link DAO automatically injected

helper - Ambari management helper automatically injected

Throws:

org.apache.ambari.server.AmbariException - if an exception occurs while processing the stacks

Method Detail

parseDirectories

protected void parseDirectories(File stackRoot,
                                File commonServicesRoot,
                                File extensionRoot)
                         throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

getStack

public StackInfo getStack(String name,
                          String version)

Obtain the stack info specified by name and version.

Parameters:

name - name of the stack

version - version of the stack

Returns:

The stack corresponding to the specified name and version. If no matching stack exists, null is returned.

getStacks

public Collection<StackInfo> getStacks(String name)

Obtain all stacks for the given name.

Parameters:

name - stack name

Returns:

A collection of all stacks with the given name. If no stacks match the specified name, an empty collection is returned.

getStacksByName

public Map<String,List<StackInfo>> getStacksByName()

Obtain all a map of all stacks by name.

Returns:

A map of all stacks with the name as the key.

getStacks

public Collection<StackInfo> getStacks()

Obtain all stacks.

Returns:

collection of all stacks

getExtension

public ExtensionInfo getExtension(String name,
                                  String version)

Obtain the extension info specified by name and version.

Parameters:

name - name of the extension

version - version of the extension

Returns:

The extension corresponding to the specified name and version. If no matching stack exists, null is returned.

getExtensions

public Collection<ExtensionInfo> getExtensions(String name)

Obtain all extensions for the given name.

Parameters:

name - extension name

Returns:

A collection of all extensions with the given name. If no extensions match the specified name, an empty collection is returned.

getExtensions

public Collection<ExtensionInfo> getExtensions()

Obtain all extensions.

Returns:

collection of all extensions

haveAllRepoUrlsBeenResolved

public boolean haveAllRepoUrlsBeenResolved()

Determine if all tasks which update stack repo urls have completed.

Returns:

true if all of the repo update tasks have completed; false otherwise

getPropertySchemaValidator

public static Validator getPropertySchemaValidator()
                                            throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

validateAllPropertyXmlsInFolderRecursively

public static void validateAllPropertyXmlsInFolderRecursively(File stackRoot,
                                                              Validator validator)
                                                       throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

linkStackToExtension

public void linkStackToExtension(StackInfo stack,
                                 ExtensionInfo extension)
                          throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

unlinkStackAndExtension

public void unlinkStackAndExtension(StackInfo stack,
                                    ExtensionInfo extension)
                             throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

removeStack

public void removeStack(StackEntity stackEntity)