org.apache.ambari.server.actionmanager

Class ActionManager

java.lang.Object

org.apache.ambari.server.actionmanager.ActionManager

public class ActionManager
extends Object

This class acts as the interface for action manager with other components.

Constructor Summary

Constructors

Constructor and Description
ActionManager(ActionDBAccessor db, RequestFactory requestFactory, org.apache.ambari.server.actionmanager.ActionScheduler scheduler) Guice-injected Constructor.

Method Summary

Modifier and Type	Method and Description
void	cancelRequest(long requestId, String reason)
Stage	getAction(long requestId, long stageId)
List<Stage>	getActions(long requestId) Get all actions(stages) for a request.
List<HostRoleCommand>	getAllTasksByRequestIds(Collection<Long> requestIds)
long	getNextRequestId()
Map<Long,String>	getRequestContext(List<Long> requestIds)
String	getRequestContext(long requestId)
List<Request>	getRequests(Collection<Long> requestIds)
List<Long>	getRequestsByStatus(RequestStatus status, int maxResults, boolean ascOrder) Get first or last maxResults requests that are in the specified status
List<Stage>	getRequestStatus(long requestId)
List<HostRoleCommand>	getRequestTasks(long requestId)
HostRoleCommand	getTaskById(long taskId)
Collection<HostRoleCommand>	getTasks(Collection<Long> taskIds)
Map<Long,HostRoleCommand>	getTasksMap(Collection<Long> taskIds)
void	handleLostHost(String host)
boolean	isInProgressCommand(CommandReport report) Find if the command report is for an in progress command
void	processTaskResponse(String hostname, List<CommandReport> reports, Map<Long,HostRoleCommand> commands) Persists command reports into the db
void	resubmitTasks(List<Long> taskIds)
void	sendActions(List<Stage> stages, String clusterHostInfo, ExecuteActionRequest actionRequest)
void	sendActions(Request request, ExecuteActionRequest executeActionRequest)
static void	setTopologyManager(TopologyManager topologyManager)
void	shutdown()
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

ActionManager

@Inject
public ActionManager(ActionDBAccessor db,
                             RequestFactory requestFactory,
                             org.apache.ambari.server.actionmanager.ActionScheduler scheduler)

Guice-injected Constructor.

Parameters:

db -

requestFactory -

scheduler -

Method Detail

start

public void start()

shutdown

public void shutdown()

sendActions

public void sendActions(List<Stage> stages,
                        String clusterHostInfo,
                        ExecuteActionRequest actionRequest)
                 throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

sendActions

public void sendActions(Request request,
                        ExecuteActionRequest executeActionRequest)
                 throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

getRequests

public List<Request> getRequests(Collection<Long> requestIds)

getRequestStatus

public List<Stage> getRequestStatus(long requestId)

getAction

public Stage getAction(long requestId,
                       long stageId)

getActions

public List<Stage> getActions(long requestId)

Get all actions(stages) for a request.

Parameters:

requestId - the request id

Returns:

list of all stages associated with the given request id

getTaskById

public HostRoleCommand getTaskById(long taskId)

processTaskResponse

public void processTaskResponse(String hostname,
                                List<CommandReport> reports,
                                Map<Long,HostRoleCommand> commands)

Persists command reports into the db

Parameters:

reports - command reports

commands - a list of commands that correspond to reports list (it should be a 1 to 1 matching). We use this list to avoid fetching commands from the DB twice

isInProgressCommand

public boolean isInProgressCommand(CommandReport report)

Find if the command report is for an in progress command

Parameters:

report -

Returns:

handleLostHost

public void handleLostHost(String host)

getNextRequestId

public long getNextRequestId()

getRequestTasks

public List<HostRoleCommand> getRequestTasks(long requestId)

getAllTasksByRequestIds

public List<HostRoleCommand> getAllTasksByRequestIds(Collection<Long> requestIds)

getTasks

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

getTasksMap

public Map<Long,HostRoleCommand> getTasksMap(Collection<Long> taskIds)

getRequestsByStatus

public List<Long> getRequestsByStatus(RequestStatus status,
                                      int maxResults,
                                      boolean ascOrder)

Get first or last maxResults requests that are in the specified status

Parameters:

status - Desired request status

maxResults - maximal number of returned id's

ascOrder - defines sorting order for database query result

Returns:

First or last maxResults request id's if ascOrder is true or false, respectively

getRequestContext

public Map<Long,String> getRequestContext(List<Long> requestIds)

getRequestContext

public String getRequestContext(long requestId)

cancelRequest

public void cancelRequest(long requestId,
                          String reason)

setTopologyManager

public static void setTopologyManager(TopologyManager topologyManager)

resubmitTasks

public void resubmitTasks(List<Long> taskIds)