org.apache.ambari.server.state.cluster

Class ClustersImpl

java.lang.Object

org.apache.ambari.server.state.cluster.ClustersImpl

All Implemented Interfaces:

Clusters

public class ClustersImpl
extends Object
implements Clusters

Constructor Summary

Constructors

Constructor and Description
ClustersImpl(ClusterDAO clusterDAO, ClusterFactory clusterFactory, HostDAO hostDAO, HostFactory hostFactory)

Method Summary

Modifier and Type	Method and Description
void	addCluster(String clusterName, StackId stackId) Add a new Cluster
void	addCluster(String clusterName, StackId stackId, SecurityType securityType) Add a new cluster
void	addHost(String hostname) Register a host by creating a HostEntity object in the database and setting its state to HostState.INIT.
void	addSessionAttributes(String name, Map<String,Object> attributes) Add the given map of attributes to the session for the cluster identified by the given name.
boolean	checkPermission(String clusterName, boolean readOnly) Determine whether or not access to the cluster resource identified by the given cluster name should be allowed based on the permissions granted to the current user.
void	debugDump(StringBuilder sb) Produces a debug dump into the supplied string buffer
void	deleteCluster(String clusterName) Deletes the cluster identified by the name
void	deleteHost(String hostname) Delete a host entirely from the cluster and all database tables, except AlertHistory.
protected Cluster	findCluster(String name) Find the cluster for the given name.
Cluster	getCluster(Long clusterId) Gets the Cluster given the cluster id
Cluster	getCluster(String clusterName) Gets the Cluster given the cluster name
Cluster	getClusterById(long id) Gets the cluster using the id.
Map<String,Cluster>	getClusters() Get all clusters
Set<Cluster>	getClustersForHost(String hostname) Returns all the cluster names for this hostname
int	getClusterSize(String clusterName) Returns the number of hosts that form the cluster identified by the given name.
Host	getHost(String hostname) Get a Host object managed by this server
Host	getHostById(Long hostId) Get a Host object managed by this server
Map<Long,Host>	getHostIdsForCluster(String clusterName) Gets all the host Ids associated with the cluster
List<Host>	getHosts() Get all hosts being tracked by the Ambari server
Map<String,Host>	getHostsForCluster(String clusterName) Gets all the hosts associated with the cluster
Map<String,Object>	getSessionAttributes(String name) Get the map of session attributes for the cluster identified by the given name.
boolean	hostExists(String hostname) Check if host exists
void	invalidate(Cluster cluster) Invalidates the specified cluster by retrieving it from the database and refreshing all of the internal stateful collections.
void	invalidateAllClusters() Invalidates all clusters by retrieving each from the database and refreshing all of its internal stateful collections.
boolean	isHostMappedToCluster(long clusterId, String hostName) Gets whether the specified cluster has a mapping for the specified host.
void	mapAndPublishHostsToCluster(Set<String> hostnames, String clusterName) For each host, attempts to map it to the cluster, and apply the cluster's current version to the host.
void	mapHostToCluster(String hostname, String clusterName) Attempts to map the host to the cluster via clusterhostmapping table if not already present, and add a host_version record for the cluster's currently applied (stack, version) if not already present.
void	publishHostsDeletion(Set<Long> hostIds, Set<String> hostNames) Publish event set of hosts were removed
void	unmapHostFromCluster(String hostname, String clusterName) Removes a host from a cluster.
void	updateClusterName(String oldName, String newName) Updates the name of the cluster
void	updateHostMappings(Host host) Updates the internal mappings of hosts using the specified host.
void	updateHostWithClusterAndAttributes(Map<String,Set<String>> hostClusters, Map<String,Map<String,String>> hostAttributes) Update the host set for clusters and the host attributes associated with the hosts

Methods inherited from class java.lang.Object

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

Constructor Detail

ClustersImpl

@Inject
public ClustersImpl(ClusterDAO clusterDAO,
                            ClusterFactory clusterFactory,
                            HostDAO hostDAO,
                            HostFactory hostFactory)

Method Detail

addCluster

public void addCluster(String clusterName,
                       StackId stackId)
                throws org.apache.ambari.server.AmbariException

Description copied from interface: Clusters

Add a new Cluster

Specified by:

addCluster in interface Clusters

Parameters:

clusterName - the cluster name (not null).

stackId - the stack for the cluster (not null).

Throws:

org.apache.ambari.server.AmbariException

addCluster

public void addCluster(String clusterName,
                       StackId stackId,
                       SecurityType securityType)
                throws org.apache.ambari.server.AmbariException

Description copied from interface: Clusters

Add a new cluster

Specified by:

addCluster in interface Clusters

Parameters:

clusterName - the cluster name (not null).

stackId - the stack for the cluster (not null).

securityType - the cluster will be created with this security type.

Throws:

org.apache.ambari.server.AmbariException

getCluster

public Cluster getCluster(String clusterName)
                   throws org.apache.ambari.server.AmbariException

Description copied from interface: Clusters

Gets the Cluster given the cluster name

Specified by:

getCluster in interface Clusters

Parameters:

clusterName - Name of the Cluster to retrieve

Returns:

Cluster identified by the given name

Throws:

org.apache.ambari.server.AmbariException

getCluster

public Cluster getCluster(Long clusterId)
                   throws org.apache.ambari.server.AmbariException

Description copied from interface: Clusters

Gets the Cluster given the cluster id

Specified by:

getCluster in interface Clusters

Parameters:

clusterId - Id of the Cluster to retrieve

Returns:

Cluster identified by the given id

Throws:

org.apache.ambari.server.AmbariException

getClusterById

public Cluster getClusterById(long id)
                       throws org.apache.ambari.server.AmbariException

Description copied from interface: Clusters

Gets the cluster using the id.

Specified by:

getClusterById in interface Clusters

Parameters:

id - The identifier associated with the cluster

Returns:

Cluster identified by the identifier

Throws:

org.apache.ambari.server.AmbariException

getHosts

public List<Host> getHosts()

Description copied from interface: Clusters

Get all hosts being tracked by the Ambari server

Specified by:

getHosts in interface Clusters

Returns:

List of Host

getClustersForHost

public Set<Cluster> getClustersForHost(String hostname)
                                throws org.apache.ambari.server.AmbariException

Description copied from interface: Clusters

Returns all the cluster names for this hostname

Specified by:

getClustersForHost in interface Clusters

Returns:

List of cluster names

Throws:

org.apache.ambari.server.AmbariException

getHost

public Host getHost(String hostname)
             throws org.apache.ambari.server.AmbariException

Description copied from interface: Clusters

Get a Host object managed by this server

Specified by:

getHost in interface Clusters

Parameters:

hostname - Name of the host requested

Returns:

Host object

Throws:

org.apache.ambari.server.AmbariException

hostExists

public boolean hostExists(String hostname)

Description copied from interface: Clusters

Check if host exists

Specified by:

hostExists in interface Clusters

Parameters:

hostname - Name of the host requested

Returns:

is host exists

isHostMappedToCluster

public boolean isHostMappedToCluster(long clusterId,
                                     String hostName)

Gets whether the specified cluster has a mapping for the specified host.

Specified by:

isHostMappedToCluster in interface Clusters

Parameters:

clusterId - the cluster ID

hostName - the host (not null).

Returns:

true if the host belongs to the cluster, false otherwise.

getHostById

public Host getHostById(Long hostId)
                 throws org.apache.ambari.server.AmbariException

Description copied from interface: Clusters

Get a Host object managed by this server

Specified by:

getHostById in interface Clusters

Parameters:

hostId - Host Id from the HostEntity objecty

Returns:

Host object

Throws:

org.apache.ambari.server.AmbariException

updateHostMappings

public void updateHostMappings(Host host)

Updates the internal mappings of hosts using the specified host.

Specified by:

updateHostMappings in interface Clusters

Parameters:

host - the host to update the internal mappings for.

addHost

public void addHost(String hostname)
             throws org.apache.ambari.server.AmbariException

Register a host by creating a HostEntity object in the database and setting its state to HostState.INIT. This does not add the host the cluster.

Specified by:

addHost in interface Clusters

Parameters:

hostname - Host to be added

Throws:

org.apache.ambari.server.AmbariException

updateHostWithClusterAndAttributes

public void updateHostWithClusterAndAttributes(Map<String,Set<String>> hostClusters,
                                               Map<String,Map<String,String>> hostAttributes)
                                        throws org.apache.ambari.server.AmbariException

Description copied from interface: Clusters

Update the host set for clusters and the host attributes associated with the hosts

Specified by:

updateHostWithClusterAndAttributes in interface Clusters

Throws:

org.apache.ambari.server.AmbariException

mapAndPublishHostsToCluster

public void mapAndPublishHostsToCluster(Set<String> hostnames,
                                        String clusterName)
                                 throws org.apache.ambari.server.AmbariException

For each host, attempts to map it to the cluster, and apply the cluster's current version to the host.

Specified by:

mapAndPublishHostsToCluster in interface Clusters

Parameters:

hostnames - Collection of host names

clusterName - Cluster name

Throws:

org.apache.ambari.server.AmbariException

mapHostToCluster

public void mapHostToCluster(String hostname,
                             String clusterName)
                      throws org.apache.ambari.server.AmbariException

Attempts to map the host to the cluster via clusterhostmapping table if not already present, and add a host_version record for the cluster's currently applied (stack, version) if not already present.

Specified by:

mapHostToCluster in interface Clusters

Parameters:

hostname - Host name

clusterName - Cluster name

Throws:

org.apache.ambari.server.AmbariException - May throw a DuplicateResourceException.

getClusters

public Map<String,Cluster> getClusters()

Description copied from interface: Clusters

Get all clusters

Specified by:

getClusters in interface Clusters

Returns:

Map of clusters with cluster name as key

updateClusterName

public void updateClusterName(String oldName,
                              String newName)

Description copied from interface: Clusters

Updates the name of the cluster

Specified by:

updateClusterName in interface Clusters

debugDump

public void debugDump(StringBuilder sb)

Description copied from interface: Clusters

Produces a debug dump into the supplied string buffer

Specified by:

debugDump in interface Clusters

Parameters:

sb - The string buffer to add the debug dump to

getHostsForCluster

public Map<String,Host> getHostsForCluster(String clusterName)

Description copied from interface: Clusters

Gets all the hosts associated with the cluster

Specified by:

getHostsForCluster in interface Clusters

Parameters:

clusterName - The name of the cluster

Returns:

Map containing host name and Host

getHostIdsForCluster

public Map<Long,Host> getHostIdsForCluster(String clusterName)
                                    throws org.apache.ambari.server.AmbariException

Description copied from interface: Clusters

Gets all the host Ids associated with the cluster

Specified by:

getHostIdsForCluster in interface Clusters

Parameters:

clusterName - The name of the cluster

Returns:

Map containing host id and Host

Throws:

org.apache.ambari.server.AmbariException

deleteCluster

public void deleteCluster(String clusterName)
                   throws org.apache.ambari.server.AmbariException

Description copied from interface: Clusters

Deletes the cluster identified by the name

Specified by:

deleteCluster in interface Clusters

Parameters:

clusterName - The name of the cluster

Throws:

org.apache.ambari.server.AmbariException

unmapHostFromCluster

public void unmapHostFromCluster(String hostname,
                                 String clusterName)
                          throws org.apache.ambari.server.AmbariException

Description copied from interface: Clusters

Removes a host from a cluster. Inverts {@link #mapHostToCluster(String, String)

Specified by:

unmapHostFromCluster in interface Clusters

Throws:

org.apache.ambari.server.AmbariException

deleteHost

public void deleteHost(String hostname)
                throws org.apache.ambari.server.AmbariException

Delete a host entirely from the cluster and all database tables, except AlertHistory. If the host is not found, throws HostNotFoundException.

Specified by:

deleteHost in interface Clusters

Parameters:

hostname -

Throws:

org.apache.ambari.server.AmbariException

publishHostsDeletion

public void publishHostsDeletion(Set<Long> hostIds,
                                 Set<String> hostNames)
                          throws org.apache.ambari.server.AmbariException

Description copied from interface: Clusters

Publish event set of hosts were removed

Specified by:

publishHostsDeletion in interface Clusters

Throws:

org.apache.ambari.server.AmbariException

checkPermission

public boolean checkPermission(String clusterName,
                               boolean readOnly)

Description copied from interface: Clusters

Determine whether or not access to the cluster resource identified by the given cluster name should be allowed based on the permissions granted to the current user.

Specified by:

checkPermission in interface Clusters

Parameters:

clusterName - the cluster name

readOnly - indicate whether or not this check is for a read only operation

Returns:

true if access to the cluster is allowed

addSessionAttributes

public void addSessionAttributes(String name,
                                 Map<String,Object> attributes)

Description copied from interface: Clusters

Add the given map of attributes to the session for the cluster identified by the given name.

Specified by:

addSessionAttributes in interface Clusters

Parameters:

name - the cluster name

attributes - the session attributes

getSessionAttributes

public Map<String,Object> getSessionAttributes(String name)

Description copied from interface: Clusters

Get the map of session attributes for the cluster identified by the given name.

Specified by:

getSessionAttributes in interface Clusters

Parameters:

name - the cluster name

Returns:

the map of session attributes for the cluster; never null

getClusterSize

public int getClusterSize(String clusterName)

Returns the number of hosts that form the cluster identified by the given name.

Specified by:

getClusterSize in interface Clusters

Parameters:

clusterName - the name that identifies the cluster

Returns:

number of hosts that form the cluster

findCluster

protected Cluster findCluster(String name)

Find the cluster for the given name.

Parameters:

name - the cluster name

Returns:

the cluster for the given name; null if the cluster can not be found

invalidate

public void invalidate(Cluster cluster)

Invalidates the specified cluster by retrieving it from the database and refreshing all of the internal stateful collections.

Specified by:

invalidate in interface Clusters

Parameters:

cluster - the cluster to invalidate and refresh (not null).

invalidateAllClusters

public void invalidateAllClusters()

Invalidates all clusters by retrieving each from the database and refreshing all of its internal stateful collections.

Specified by:

invalidateAllClusters in interface Clusters