org.apache.ambari.server.topology

Class TopologyManager

java.lang.Object

org.apache.ambari.server.topology.TopologyManager

public class TopologyManager
extends Object

Manages all cluster provisioning actions on the cluster topology.

Field Summary

Fields

Modifier and Type	Field and Description
static String	INITIAL_CONFIG_TAG
static String	INTERNAL_AUTH_TOKEN internal token for topology related async tasks
static String	KDC_ADMIN_CREDENTIAL
static String	TOPOLOGY_RESOLVED_TAG

Constructor Summary

Constructors

Constructor and Description
TopologyManager()
TopologyManager(Configuration configuration)

Method Summary

Modifier and Type	Method and Description
protected LogicalRequest	createLogicalRequest(PersistedTopologyRequest request, ClusterTopology topology, Long requestId)
ClusterTopology	getClusterTopology(Long clusterId)
Map<String,Collection<String>>	getPendingHostComponents() Gets a map of components keyed by host which have operations in the HostRoleStatus.PENDING state.
LogicalRequest	getRequest(long requestId)
Collection<LogicalRequest>	getRequests(Collection<Long> requestIds)
Collection<RequestStatusResponse>	getRequestStatus(Collection<Long> ids)
RequestStatusResponse	getRequestStatus(long requestId)
Collection<StageEntity>	getStages() Currently we are just returning all stages for all requests and relying on the StageResourceProvider to convert each to a resource and do a predicate eval on each.
Map<Long,HostRoleCommandStatusSummaryDTO>	getStageSummaries(Long requestId)
Collection<HostRoleCommand>	getTasks(Collection<Long> requestIds)
Collection<HostRoleCommand>	getTasks(long requestId)
boolean	isClusterProvisionWithBlueprintFinished(long clusterId) Returns if the provision request for a cluster is finished.
boolean	isClusterProvisionWithBlueprintTracked(long clusterId) Returns if provision request for a cluster is tracked
void	onClusterConfigFinishedEvent(ClusterConfigFinishedEvent event)
void	onHostHeartBeatLost(Host host) Through this method TopologyManager gets notified when a connection to a host in the cluster is lost.
void	onHostRegistered(HostImpl host, boolean associatedWithCluster)
void	onRequestFinished(RequestFinishedEvent event) Called when heartbeat processing finishes
protected void	persistTopologyHostRegistration(long hostRequestId, HostImpl host)
protected LogicalRequest	processAndPersistProvisionClusterTopologyRequest(ProvisionClusterRequest request, ClusterTopology topology, Long logicalRequestId) Creates and persists a PersistedTopologyRequest and a LogicalRequest for the provided provision cluster request and topology.
protected LogicalRequest	processAndPersistTopologyRequest(BaseClusterRequest request, ClusterTopology topology, Long logicalRequestId) Creates and persists a PersistedTopologyRequest and a LogicalRequest for the provided request and topology.
void	processHostRemovedEvent(HostsRemovedEvent hostsRemovedEvent) Removes a host from the available hosts when the host gets deleted.
RequestStatusResponse	provisionCluster(ProvisionClusterRequest request)
void	removeHostRequests(String hostName) Removes topology host requests matched to the given host.
void	removePendingHostRequests(String clusterName, long requestId)
RequestStatusResponse	scaleHosts(ScaleClusterRequest request)

Methods inherited from class java.lang.Object

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

Field Detail

INTERNAL_AUTH_TOKEN

public static final String INTERNAL_AUTH_TOKEN

internal token for topology related async tasks

See Also:

Constant Field Values

INITIAL_CONFIG_TAG

public static final String INITIAL_CONFIG_TAG

See Also:

Constant Field Values

TOPOLOGY_RESOLVED_TAG

public static final String TOPOLOGY_RESOLVED_TAG

See Also:

Constant Field Values

KDC_ADMIN_CREDENTIAL

public static final String KDC_ADMIN_CREDENTIAL

See Also:

Constant Field Values

Constructor Detail

TopologyManager

public TopologyManager()

TopologyManager

@Inject
public TopologyManager(Configuration configuration)

Method Detail

onRequestFinished

public void onRequestFinished(RequestFinishedEvent event)

Called when heartbeat processing finishes

Parameters:

event -

isClusterProvisionWithBlueprintTracked

public boolean isClusterProvisionWithBlueprintTracked(long clusterId)

Returns if provision request for a cluster is tracked

Parameters:

clusterId -

Returns:

isClusterProvisionWithBlueprintFinished

public boolean isClusterProvisionWithBlueprintFinished(long clusterId)

Returns if the provision request for a cluster is finished. Note that this method returns false if the request is not tracked. See isClusterProvisionWithBlueprintTracked(long)

Parameters:

clusterId -

Returns:

provisionCluster

public RequestStatusResponse provisionCluster(ProvisionClusterRequest request)
                                       throws InvalidTopologyException,
                                              org.apache.ambari.server.AmbariException

Throws:

InvalidTopologyException

org.apache.ambari.server.AmbariException

onClusterConfigFinishedEvent

public void onClusterConfigFinishedEvent(ClusterConfigFinishedEvent event)

scaleHosts

public RequestStatusResponse scaleHosts(ScaleClusterRequest request)
                                 throws InvalidTopologyException,
                                        org.apache.ambari.server.AmbariException

Throws:

InvalidTopologyException

org.apache.ambari.server.AmbariException

removePendingHostRequests

public void removePendingHostRequests(String clusterName,
                                      long requestId)

removeHostRequests

public void removeHostRequests(String hostName)

Removes topology host requests matched to the given host. If the parent request has no more child host requests, then it is also removed. This is used when hosts are deleted from the cluster.

Parameters:

hostName - the host name for which requests should be removed

processAndPersistProvisionClusterTopologyRequest

protected LogicalRequest processAndPersistProvisionClusterTopologyRequest(ProvisionClusterRequest request,
                                                                          ClusterTopology topology,
                                                                          Long logicalRequestId)
                                                                   throws InvalidTopologyException,
                                                                          org.apache.ambari.server.AmbariException

Creates and persists a PersistedTopologyRequest and a LogicalRequest for the provided provision cluster request and topology.

Parameters:

request - Provision cluster request to create a logical request for.

topology - Cluster topology

logicalRequestId - The Id for the created logical request

Returns:

Logical request created.

Throws:

InvalidTopologyException

org.apache.ambari.server.AmbariException

processAndPersistTopologyRequest

protected LogicalRequest processAndPersistTopologyRequest(BaseClusterRequest request,
                                                          ClusterTopology topology,
                                                          Long logicalRequestId)
                                                   throws InvalidTopologyException,
                                                          org.apache.ambari.server.AmbariException

Creates and persists a PersistedTopologyRequest and a LogicalRequest for the provided request and topology.

Parameters:

request - ProvisionClusterRequest or ScaleClusterRequest to create a logical request for.

topology - Cluster topology

logicalRequestId - The Id for the created logical request

Returns:

Logical request created.

Throws:

InvalidTopologyException

org.apache.ambari.server.AmbariException

onHostRegistered

public void onHostRegistered(HostImpl host,
                             boolean associatedWithCluster)

onHostHeartBeatLost

public void onHostHeartBeatLost(Host host)

Through this method TopologyManager gets notified when a connection to a host in the cluster is lost. The passed host will be excluded from scheduling any tasks onto it as it can't be reached.

Parameters:

host -

getRequest

public LogicalRequest getRequest(long requestId)

getRequests

public Collection<LogicalRequest> getRequests(Collection<Long> requestIds)

getStages

public Collection<StageEntity> getStages()

Currently we are just returning all stages for all requests and relying on the StageResourceProvider to convert each to a resource and do a predicate eval on each.

getTasks

public Collection<HostRoleCommand> getTasks(long requestId)

getTasks

public Collection<HostRoleCommand> getTasks(Collection<Long> requestIds)

getStageSummaries

public Map<Long,HostRoleCommandStatusSummaryDTO> getStageSummaries(Long requestId)

getRequestStatus

public RequestStatusResponse getRequestStatus(long requestId)

getRequestStatus

public Collection<RequestStatusResponse> getRequestStatus(Collection<Long> ids)

getClusterTopology

public ClusterTopology getClusterTopology(Long clusterId)

getPendingHostComponents

public Map<String,Collection<String>> getPendingHostComponents()

Gets a map of components keyed by host which have operations in the HostRoleStatus.PENDING state. This could either be because hosts have not registered or becuase the operations are actually waiting to be queued.

Returns:

a mapping of host with pending components.

createLogicalRequest

protected LogicalRequest createLogicalRequest(PersistedTopologyRequest request,
                                              ClusterTopology topology,
                                              Long requestId)
                                       throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

persistTopologyHostRegistration

protected void persistTopologyHostRegistration(long hostRequestId,
                                               HostImpl host)

processHostRemovedEvent

public void processHostRemovedEvent(HostsRemovedEvent hostsRemovedEvent)

Removes a host from the available hosts when the host gets deleted.

Parameters:

hostsRemovedEvent - the event containing the hostname