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()

Method Summary

Modifier and Type	Method and Description
void	addCluster(String clusterName) Add a new Cluster
void	addHost(String hostname) Add a Host object to be managed by this server
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) Removes a host.
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
Host	getHost(String hostname) Get a Host object managed by this server
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
void	mapHostsToCluster(Set<String> hostnames, String clusterName) Maps a set of hosts to the given cluster
void	mapHostToCluster(String hostname, String clusterName) Map host to the given cluster.
void	setCurrentStackVersion(String clusterName, StackId stackId) Sets the current stack version for the cluster
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	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()

Method Detail

addCluster

public void addCluster(String clusterName)
                throws AmbariException

Description copied from interface: Clusters

Add a new Cluster

Specified by:

addCluster in interface Clusters

Throws:

AmbariException

getCluster

public Cluster getCluster(String clusterName)
                   throws 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:

AmbariException

getClusterById

public Cluster getClusterById(long id)
                       throws 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:

AmbariException

setCurrentStackVersion

public void setCurrentStackVersion(String clusterName,
                                   StackId stackId)
                            throws AmbariException

Description copied from interface: Clusters

Sets the current stack version for the cluster

Specified by:

setCurrentStackVersion in interface Clusters

Parameters:

clusterName - The name of the cluster

stackId - The identifier for the stack

Throws:

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 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:

AmbariException

getHost

public Host getHost(String hostname)
             throws 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:

AmbariException

addHost

public void addHost(String hostname)
             throws AmbariException

Description copied from interface: Clusters

Add a Host object to be managed by this server

Specified by:

addHost in interface Clusters

Parameters:

hostname - Host to be added

Throws:

AmbariException

updateHostWithClusterAndAttributes

public void updateHostWithClusterAndAttributes(Map<String,Set<String>> hostClusters,
                                               Map<String,Map<String,String>> hostAttributes)
                                        throws 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:

AmbariException

mapHostToCluster

public void mapHostToCluster(String hostname,
                             String clusterName)
                      throws AmbariException

Description copied from interface: Clusters

Map host to the given cluster. A host can belong to multiple clusters

Specified by:

mapHostToCluster in interface Clusters

Throws:

AmbariException

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

mapHostsToCluster

public void mapHostsToCluster(Set<String> hostnames,
                              String clusterName)
                       throws AmbariException

Description copied from interface: Clusters

Maps a set of hosts to the given cluster

Specified by:

mapHostsToCluster in interface Clusters

Throws:

AmbariException

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)
                                    throws AmbariException

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

Throws:

AmbariException

deleteCluster

public void deleteCluster(String clusterName)
                   throws 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:

AmbariException

unmapHostFromCluster

public void unmapHostFromCluster(String hostname,
                                 String clusterName)
                          throws AmbariException

Description copied from interface: Clusters

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

Specified by:

unmapHostFromCluster in interface Clusters

Throws:

AmbariException

deleteHost

public void deleteHost(String hostname)
                throws AmbariException

Description copied from interface: Clusters

Removes a host. Inverts Clusters.addHost(String)

Specified by:

deleteHost in interface Clusters

Throws:

AmbariException