org.apache.ambari.server.state.cluster

Class ClusterImpl

java.lang.Object

org.apache.ambari.server.state.cluster.ClusterImpl

All Implemented Interfaces:

Cluster

public class ClusterImpl
extends Object
implements Cluster

Constructor Summary

Constructors

Constructor and Description
ClusterImpl(ClusterEntity clusterEntity, com.google.inject.Injector injector)

Method Summary

Modifier and Type	Method and Description
void	addConfig(Config config) Sets a specific config.
void	addConfigGroup(ConfigGroup configGroup) Add a new config group to the set of Config groups associated with this cluster
boolean	addDesiredConfig(String user, Config config) Adds and sets a DESIRED configuration to be applied to a cluster.
void	addRequestExecution(RequestExecution requestExecution) Add a @RequestExecution to the cluster
void	addService(Service service) Add a service to a cluster
Service	addService(String serviceName) Add service to the cluster
void	addServiceComponentHost(ServiceComponentHost svcCompHost)
boolean	canBeRemoved() Gets if the cluster can be deleted
ClusterResponse	convertToResponse() Creates a cluster response based on the current cluster definition
void	debugDump(StringBuilder sb) Creates a debug dump based on the current cluster state
void	delete() Delete the cluster
void	deleteAllServices() Delete all the services associated with this cluster
void	deleteConfigGroup(Long id) Delete this config group identified by the config group id
void	deleteRequestExecution(Long id) Delete a @RequestExecution associated with the cluster
void	deleteService(String serviceName) Delete the named service associated with this cluster
Collection<Config>	getAllConfigs() Gets all configurations defined for a cluster.
Map<String,Map<String,DesiredConfig>>	getAllHostsDesiredConfigs() Fetch desired configs for all hosts in cluster
Map<Long,RequestExecution>	getAllRequestExecutions() Get all @RequestExecution objects associated with the cluster
ReadWriteLock	getClusterGlobalLock() Get lock to control access to cluster structure
long	getClusterId() Get the cluster ID
String	getClusterName() Get the Cluster Name
Config	getConfig(String configType, String versionTag) Gets the specific config that matches the specified type and tag.
Map<Long,ConfigGroup>	getConfigGroups() Get all config groups associated with this cluster
Map<Long,ConfigGroup>	getConfigGroupsByHostname(String hostname) Find all config groups associated with the give hostname
Map<String,Config>	getConfigsByType(String configType) Gets all configs that match the specified type.
StackId	getCurrentStackVersion() Get current stack version
Config	getDesiredConfigByType(String configType) Gets the desired (and selected) config by type.
Map<String,DesiredConfig>	getDesiredConfigs() Gets the desired configurations for the cluster.
StackId	getDesiredStackVersion() Get desired stack version
Map<String,Map<String,DesiredConfig>>	getHostsDesiredConfigs(Collection<String> hostnames) Fetch desired configs for list of hosts in cluster
Service	getService(String serviceName) Get a service
ServiceComponentHost	getServiceComponentHost(String serviceName, String serviceComponentName, String hostname)
List<ServiceComponentHost>	getServiceComponentHosts(String hostname) Get all ServiceComponentHosts on a given host
Map<String,Service>	getServices() Get all services
void	loadServiceHostComponents() Make sure we load all the service host components.
void	refresh() Refreshes the cluster details
protected void	removeEntities()
void	removeServiceComponentHost(ServiceComponentHost svcCompHost) Remove ServiceComponentHost from cluster
void	setClusterName(String clusterName) Set the Cluster Name
void	setCurrentStackVersion(StackId stackVersion) Set current stack version
void	setDesiredStackVersion(StackId stackVersion) Set desired stack version

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterImpl

@Inject
public ClusterImpl(ClusterEntity clusterEntity,
                           com.google.inject.Injector injector)

Method Detail

getClusterGlobalLock

public ReadWriteLock getClusterGlobalLock()

Description copied from interface: Cluster

Get lock to control access to cluster structure

Specified by:

getClusterGlobalLock in interface Cluster

Returns:

cluster-global lock

loadServiceHostComponents

public void loadServiceHostComponents()

Make sure we load all the service host components. We need this for live status checks.

addConfigGroup

public void addConfigGroup(ConfigGroup configGroup)
                    throws AmbariException

Description copied from interface: Cluster

Add a new config group to the set of Config groups associated with this cluster

Specified by:

addConfigGroup in interface Cluster

Throws:

AmbariException

getConfigGroups

public Map<Long,ConfigGroup> getConfigGroups()
                                      throws AmbariException

Description copied from interface: Cluster

Get all config groups associated with this cluster

Specified by:

getConfigGroups in interface Cluster

Returns:

Throws:

AmbariException

getConfigGroupsByHostname

public Map<Long,ConfigGroup> getConfigGroupsByHostname(String hostname)
                                                throws AmbariException

Description copied from interface: Cluster

Find all config groups associated with the give hostname

Specified by:

getConfigGroupsByHostname in interface Cluster

Returns:

Map of config group id to config group

Throws:

AmbariException

addRequestExecution

public void addRequestExecution(RequestExecution requestExecution)
                         throws AmbariException

Description copied from interface: Cluster

Add a @RequestExecution to the cluster

Specified by:

addRequestExecution in interface Cluster

Throws:

AmbariException

getAllRequestExecutions

public Map<Long,RequestExecution> getAllRequestExecutions()

Description copied from interface: Cluster

Get all @RequestExecution objects associated with the cluster

Specified by:

getAllRequestExecutions in interface Cluster

Returns:

deleteRequestExecution

public void deleteRequestExecution(Long id)
                            throws AmbariException

Description copied from interface: Cluster

Delete a @RequestExecution associated with the cluster

Specified by:

deleteRequestExecution in interface Cluster

Throws:

AmbariException

deleteConfigGroup

public void deleteConfigGroup(Long id)
                       throws AmbariException

Description copied from interface: Cluster

Delete this config group identified by the config group id

Specified by:

deleteConfigGroup in interface Cluster

Throws:

AmbariException

getServiceComponentHost

public ServiceComponentHost getServiceComponentHost(String serviceName,
                                                    String serviceComponentName,
                                                    String hostname)
                                             throws AmbariException

Throws:

AmbariException

getClusterName

public String getClusterName()

Description copied from interface: Cluster

Get the Cluster Name

Specified by:

getClusterName in interface Cluster

setClusterName

public void setClusterName(String clusterName)

Description copied from interface: Cluster

Set the Cluster Name

Specified by:

setClusterName in interface Cluster

addServiceComponentHost

public void addServiceComponentHost(ServiceComponentHost svcCompHost)
                             throws AmbariException

Throws:

AmbariException

removeServiceComponentHost

public void removeServiceComponentHost(ServiceComponentHost svcCompHost)
                                throws AmbariException

Description copied from interface: Cluster

Remove ServiceComponentHost from cluster

Specified by:

removeServiceComponentHost in interface Cluster

Throws:

AmbariException

getClusterId

public long getClusterId()

Description copied from interface: Cluster

Get the cluster ID

Specified by:

getClusterId in interface Cluster

getServiceComponentHosts

public List<ServiceComponentHost> getServiceComponentHosts(String hostname)

Description copied from interface: Cluster

Get all ServiceComponentHosts on a given host

Specified by:

getServiceComponentHosts in interface Cluster

Returns:

addService

public void addService(Service service)
                throws AmbariException

Description copied from interface: Cluster

Add a service to a cluster

Specified by:

addService in interface Cluster

Throws:

AmbariException

addService

public Service addService(String serviceName)
                   throws AmbariException

Description copied from interface: Cluster

Add service to the cluster

Specified by:

addService in interface Cluster

Returns:

Throws:

AmbariException

getService

public Service getService(String serviceName)
                   throws AmbariException

Description copied from interface: Cluster

Get a service

Specified by:

getService in interface Cluster

Returns:

Throws:

AmbariException

getServices

public Map<String,Service> getServices()

Description copied from interface: Cluster

Get all services

Specified by:

getServices in interface Cluster

Returns:

getDesiredStackVersion

public StackId getDesiredStackVersion()

Description copied from interface: Cluster

Get desired stack version

Specified by:

getDesiredStackVersion in interface Cluster

Returns:

setDesiredStackVersion

public void setDesiredStackVersion(StackId stackVersion)

Description copied from interface: Cluster

Set desired stack version

Specified by:

setDesiredStackVersion in interface Cluster

getCurrentStackVersion

public StackId getCurrentStackVersion()

Description copied from interface: Cluster

Get current stack version

Specified by:

getCurrentStackVersion in interface Cluster

Returns:

setCurrentStackVersion

public void setCurrentStackVersion(StackId stackVersion)
                            throws AmbariException

Description copied from interface: Cluster

Set current stack version

Specified by:

setCurrentStackVersion in interface Cluster

Throws:

AmbariException

getConfigsByType

public Map<String,Config> getConfigsByType(String configType)

Description copied from interface: Cluster

Gets all configs that match the specified type. Result is not the DESIRED configuration for a cluster.

Specified by:

getConfigsByType in interface Cluster

Parameters:

configType - the config type to return

Returns:

a map of configuration objects that have been set for the given type

getConfig

public Config getConfig(String configType,
                        String versionTag)

Description copied from interface: Cluster

Gets the specific config that matches the specified type and tag. This not necessarily a DESIRED configuration that applies to a cluster.

Specified by:

getConfig in interface Cluster

Parameters:

configType - the config type to find

versionTag - the config version to find

Returns:

a Config object, or null if the specific type and version have not been set.

addConfig

public void addConfig(Config config)

Description copied from interface: Cluster

Sets a specific config. NOTE: This is not a DESIRED configuration that applies to a cluster.

Specified by:

addConfig in interface Cluster

Parameters:

config - the config instance to add

getAllConfigs

public Collection<Config> getAllConfigs()

Description copied from interface: Cluster

Gets all configurations defined for a cluster.

Specified by:

getAllConfigs in interface Cluster

Returns:

the collection of all configs that have been defined.

convertToResponse

public ClusterResponse convertToResponse()
                                  throws AmbariException

Description copied from interface: Cluster

Creates a cluster response based on the current cluster definition

Specified by:

convertToResponse in interface Cluster

Returns:

Throws:

AmbariException

debugDump

public void debugDump(StringBuilder sb)

Description copied from interface: Cluster

Creates a debug dump based on the current cluster state

Specified by:

debugDump in interface Cluster

refresh

public void refresh()

Description copied from interface: Cluster

Refreshes the cluster details

Specified by:

refresh in interface Cluster

deleteAllServices

public void deleteAllServices()
                       throws AmbariException

Description copied from interface: Cluster

Delete all the services associated with this cluster

Specified by:

deleteAllServices in interface Cluster

Throws:

AmbariException

deleteService

public void deleteService(String serviceName)
                   throws AmbariException

Description copied from interface: Cluster

Delete the named service associated with this cluster

Specified by:

deleteService in interface Cluster

Throws:

AmbariException

canBeRemoved

public boolean canBeRemoved()

Description copied from interface: Cluster

Gets if the cluster can be deleted

Specified by:

canBeRemoved in interface Cluster

Returns:

delete

public void delete()
            throws AmbariException

Description copied from interface: Cluster

Delete the cluster

Specified by:

delete in interface Cluster

Throws:

AmbariException

removeEntities

protected void removeEntities()
                       throws AmbariException

Throws:

AmbariException

addDesiredConfig

public boolean addDesiredConfig(String user,
                                Config config)

Description copied from interface: Cluster

Adds and sets a DESIRED configuration to be applied to a cluster. There can be only one selected config per type.

Specified by:

addDesiredConfig in interface Cluster

Parameters:

user - the user making the change for audit purposes

config - the Config object to set as desired

Returns:

true if the config was added, or false if the config is already set as the current

getDesiredConfigs

public Map<String,DesiredConfig> getDesiredConfigs()

Description copied from interface: Cluster

Gets the desired configurations for the cluster.

Specified by:

getDesiredConfigs in interface Cluster

Returns:

a map of type-to-configuration information.

getDesiredConfigByType

public Config getDesiredConfigByType(String configType)

Description copied from interface: Cluster

Gets the desired (and selected) config by type.

Specified by:

getDesiredConfigByType in interface Cluster

Parameters:

configType - the type of configuration

Returns:

the Config instance, or null if the type has not been set.

getHostsDesiredConfigs

public Map<String,Map<String,DesiredConfig>> getHostsDesiredConfigs(Collection<String> hostnames)

Description copied from interface: Cluster

Fetch desired configs for list of hosts in cluster

Specified by:

getHostsDesiredConfigs in interface Cluster

Returns:

getAllHostsDesiredConfigs

public Map<String,Map<String,DesiredConfig>> getAllHostsDesiredConfigs()

Description copied from interface: Cluster

Fetch desired configs for all hosts in cluster

Specified by:

getAllHostsDesiredConfigs in interface Cluster

Returns: