org.apache.ambari.server.topology

Class HostRequest

java.lang.Object

org.apache.ambari.server.topology.HostRequest

All Implemented Interfaces:

Comparable<HostRequest>

public class HostRequest
extends Object
implements Comparable<HostRequest>

Represents a set of requests to a single host such as install, start, etc.

Constructor Summary

Constructors

Constructor and Description
HostRequest(long requestId, long id, long clusterId, String hostname, String blueprintName, HostGroup hostGroup, Predicate predicate, ClusterTopology topology, boolean skipFailure)
HostRequest(long requestId, long id, String predicate, ClusterTopology topology, TopologyHostRequestEntity entity, boolean skipFailure) Only to be used when replaying persisted requests upon server startup.

Method Summary

Modifier and Type	Method and Description
void	abortPendingTasks()
int	compareTo(HostRequest other)
boolean	containsMaster()
String	getBlueprint()
long	getClusterId()
HostGroup	getHostGroup()
String	getHostgroupName()
String	getHostName()
long	getId()
HostRoleCommand	getLogicalTask(long logicalTaskId)
Collection<HostRoleCommand>	getLogicalTasks()
Map<String,Long>	getLogicalTasksForTopologyTask(TopologyTask topologyTask)
Long	getPhysicalTaskId(long logicalTaskId)
Map<Long,Long>	getPhysicalTaskMapping()
Predicate	getPredicate()
long	getRequestId()
long	getStageId()
HostRoleStatus	getStatus()
com.google.common.base.Optional<String>	getStatusMessage()
Collection<HostRoleCommandEntity>	getTaskEntities()
List<TopologyHostTask>	getTopologyTasks()
boolean	isCompleted()
boolean	matchesHost(Host host)
org.apache.ambari.server.topology.HostOfferResponse	offer(Host host)
void	registerPhysicalTaskId(long logicalTaskId, long physicalTaskId)
void	setHostName(String hostName)
void	setStatus(HostRoleStatus status)
void	setStatusMessage(String errorMessage)
boolean	shouldSkipFailure()

Methods inherited from class java.lang.Object

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

Constructor Detail

HostRequest

public HostRequest(long requestId,
                   long id,
                   long clusterId,
                   String hostname,
                   String blueprintName,
                   HostGroup hostGroup,
                   Predicate predicate,
                   ClusterTopology topology,
                   boolean skipFailure)

HostRequest

public HostRequest(long requestId,
                   long id,
                   String predicate,
                   ClusterTopology topology,
                   TopologyHostRequestEntity entity,
                   boolean skipFailure)

Only to be used when replaying persisted requests upon server startup.

Parameters:

requestId - logical request id

id - host request id

predicate - host predicate

topology - cluster topology

entity - host request entity

Method Detail

offer

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

getStatus

public HostRoleStatus getStatus()

setStatus

public void setStatus(HostRoleStatus status)

setStatusMessage

public void setStatusMessage(String errorMessage)

getStatusMessage

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

setHostName

public void setHostName(String hostName)

getRequestId

public long getRequestId()

getClusterId

public long getClusterId()

getBlueprint

public String getBlueprint()

getHostGroup

public HostGroup getHostGroup()

getHostgroupName

public String getHostgroupName()

getPredicate

public Predicate getPredicate()

isCompleted

public boolean isCompleted()

shouldSkipFailure

public boolean shouldSkipFailure()

getTopologyTasks

public List<TopologyHostTask> getTopologyTasks()

getLogicalTasks

public Collection<HostRoleCommand> getLogicalTasks()

getLogicalTasksForTopologyTask

public Map<String,Long> getLogicalTasksForTopologyTask(TopologyTask topologyTask)

getLogicalTask

public HostRoleCommand getLogicalTask(long logicalTaskId)

getTaskEntities

public Collection<HostRoleCommandEntity> getTaskEntities()

containsMaster

public boolean containsMaster()

matchesHost

public boolean matchesHost(Host host)

getHostName

public String getHostName()

getId

public long getId()

getStageId

public long getStageId()

getPhysicalTaskId

public Long getPhysicalTaskId(long logicalTaskId)

getPhysicalTaskMapping

public Map<Long,Long> getPhysicalTaskMapping()

compareTo

public int compareTo(HostRequest other)

Specified by:

compareTo in interface Comparable<HostRequest>

registerPhysicalTaskId

public void registerPhysicalTaskId(long logicalTaskId,
                                   long physicalTaskId)

abortPendingTasks

public void abortPendingTasks()