org.apache.ambari.server.topology

Class LogicalRequest

java.lang.Object

org.apache.ambari.server.actionmanager.Request

org.apache.ambari.server.topology.LogicalRequest

public class LogicalRequest
extends Request

Logical Request implementation used to provision a cluster deployed by Blueprints.

Constructor Summary

Constructors

Constructor and Description
LogicalRequest(Long id, TopologyRequest request, ClusterTopology topology)
LogicalRequest(Long id, TopologyRequest request, ClusterTopology topology, TopologyLogicalRequestEntity requestEntity)

Method Summary

Modifier and Type	Method and Description
CalculatedStatus	calculateStatus()
List<HostRoleCommand>	getCommands()
Collection<HostRequest>	getCompletedHostRequests()
com.google.common.base.Optional<String>	getFailureReason()
Collection<HostRequest>	getHostRequests()
int	getPendingHostRequestCount()
Map<String,Collection<String>>	getProjectedTopology()
RequestStatusResponse	getRequestStatus()
Collection<String>	getReservedHosts()
Collection<StageEntity>	getStageEntities()
Map<Long,HostRoleCommandStatusSummaryDTO>	getStageSummaries()
boolean	hasPendingHostRequests()
boolean	isFinished()
boolean	isSuccessful() Returns if all the tasks in the logical request have completed state.
org.apache.ambari.server.topology.HostOfferResponse	offer(Host host)
Set<HostRequest>	removeHostRequestByHostName(String hostName) Removes all HostRequest associated with the passed host name from internal collections
Collection<HostRequest>	removePendingHostRequests(String hostGroupName) Removes pending host requests (outstanding requests not picked up by any host, where hostName is null) for a host group.

Methods inherited from class org.apache.ambari.server.actionmanager.Request

constructNewPersistenceEntity, filtersFromEntity, getClusterHostInfo, getClusterId, getClusterName, getCommandName, getCreateTime, getEndTime, getInputs, getOperationLevel, getRequestContext, getRequestId, getRequestScheduleId, getRequestType, getResourceFilters, getStages, getStartTime, getStatus, getUserName, isExclusive, operationLevelFromEntity, setClusterHostInfo, setCommandName, setEndTime, setExclusive, setInputs, setOperationLevel, setRequestContext, setRequestScheduleId, setRequestType, setResourceFilters, setStages, setStartTime, setStatus, setUserName, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

LogicalRequest

public LogicalRequest(Long id,
                      TopologyRequest request,
                      ClusterTopology topology)
               throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

LogicalRequest

public LogicalRequest(Long id,
                      TopologyRequest request,
                      ClusterTopology topology,
                      TopologyLogicalRequestEntity requestEntity)
               throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

Method Detail

offer

public org.apache.ambari.server.topology.HostOfferResponse offer(Host host)

getCommands

public List<HostRoleCommand> getCommands()

Overrides:

getCommands in class Request

getReservedHosts

public Collection<String> getReservedHosts()

hasPendingHostRequests

public boolean hasPendingHostRequests()

getCompletedHostRequests

public Collection<HostRequest> getCompletedHostRequests()

getPendingHostRequestCount

public int getPendingHostRequestCount()

getHostRequests

public Collection<HostRequest> getHostRequests()

removePendingHostRequests

public Collection<HostRequest> removePendingHostRequests(String hostGroupName)

Removes pending host requests (outstanding requests not picked up by any host, where hostName is null) for a host group.

Parameters:

hostGroupName -

Returns:

getProjectedTopology

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

getStageEntities

public Collection<StageEntity> getStageEntities()

getRequestStatus

public RequestStatusResponse getRequestStatus()

getStageSummaries

public Map<Long,HostRoleCommandStatusSummaryDTO> getStageSummaries()

removeHostRequestByHostName

public Set<HostRequest> removeHostRequestByHostName(String hostName)

Removes all HostRequest associated with the passed host name from internal collections

Parameters:

hostName - name of the host

isFinished

public boolean isFinished()

Returns:

true if all the tasks in the logical request are in completed state, false otherwise

isSuccessful

public boolean isSuccessful()

Returns if all the tasks in the logical request have completed state.

getFailureReason

public com.google.common.base.Optional<String> getFailureReason()

calculateStatus

public CalculatedStatus calculateStatus()