org.apache.ambari.server.actionmanager

Class ActionDBAccessorImpl

java.lang.Object

org.apache.ambari.server.actionmanager.ActionDBAccessorImpl

All Implemented Interfaces:

ActionDBAccessor

public class ActionDBAccessorImpl
extends Object
implements ActionDBAccessor

Constructor Summary

Constructors

Constructor and Description
ActionDBAccessorImpl(long cacheLimit)

Method Summary

Modifier and Type	Method and Description
void	abortHostRole(String host, long requestId, long stageId, String role) Mark the task as to have been aborted
void	abortHostRole(String host, long requestId, long stageId, String role, String reason) Mark the task as to have been aborted.
void	abortOperation(long requestId) Abort all outstanding operations associated with the given request
void	endRequest(long requestId)
void	endRequestIfCompleted(long requestId)
List<Stage>	getAllStages(long requestId) Get all stages associated with a single request id
List<HostRoleCommand>	getAllTasksByRequestIds(Collection<Long> requestIds) Given a list of request ids, get all the tasks that belong to these requests
long	getLastPersistedRequestIdWhenInitialized() Return the last persisted Request ID as seen when the DBAccessor object was initialized.
Request	getRequest(long requestId) Get request object by id
Map<Long,String>	getRequestContext(List<Long> requestIds) Gets request contexts associated with the list of request id
String	getRequestContext(long requestId) Gets the request context associated with the request id
List<Long>	getRequestIds() Get all requests
List<Request>	getRequests(Collection<Long> requestIds) Gets request objects by ids
List<Long>	getRequestsByStatus(RequestStatus status) Gets request id of request that are in the specified status
List<HostRoleCommand>	getRequestTasks(long requestId) Given a request id, get all the tasks that belong to this request
Stage	getStage(String actionId) Given an action id of the form requestId-stageId, retrieve the Stage
List<Stage>	getStagesByHostRoleStatus(Set<HostRoleStatus> statuses) Get all stages that contain tasks with specified host role statuses
List<Stage>	getStagesInProgress() Returns all the pending stages, including queued and not-queued.
HostRoleCommand	getTask(long taskId) Gets the host role command corresponding to the task id
List<HostRoleCommand>	getTasks(Collection<Long> taskIds) Given a list of task ids, get all the host role commands
List<HostRoleCommand>	getTasksByRequestAndTaskIds(Collection<Long> requestIds, Collection<Long> taskIds) Get a list of host role commands where the request id belongs to the input requestIds and the task id belongs to the input taskIds
void	hostRoleScheduled(Stage s, String hostname, String roleStr) Updates scheduled stage.
void	persistActions(Request request) Persists all tasks for a given request
void	setSourceScheduleForRequest(long requestId, long scheduleId) Updates request with link to source schedule
void	startRequest(long requestId)
void	timeoutHostRole(String host, long requestId, long stageId, String role) Mark the task as to have timed out
void	updateHostRoleState(String hostname, long requestId, long stageId, String role, CommandReport report) For the given host, update all the tasks based on the command report
void	updateHostRoleStates(Collection<CommandReport> reports) Update tasks according to command reports

Methods inherited from class java.lang.Object

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

Constructor Detail

ActionDBAccessorImpl

@Inject
public ActionDBAccessorImpl(long cacheLimit)

Method Detail

getStage

public Stage getStage(String actionId)

Description copied from interface: ActionDBAccessor

Given an action id of the form requestId-stageId, retrieve the Stage

Specified by:

getStage in interface ActionDBAccessor

getAllStages

public List<Stage> getAllStages(long requestId)

Description copied from interface: ActionDBAccessor

Get all stages associated with a single request id

Specified by:

getAllStages in interface ActionDBAccessor

getRequest

public Request getRequest(long requestId)

Description copied from interface: ActionDBAccessor

Get request object by id

Specified by:

getRequest in interface ActionDBAccessor

Returns:

abortOperation

public void abortOperation(long requestId)

Description copied from interface: ActionDBAccessor

Abort all outstanding operations associated with the given request

Specified by:

abortOperation in interface ActionDBAccessor

timeoutHostRole

public void timeoutHostRole(String host,
                            long requestId,
                            long stageId,
                            String role)

Description copied from interface: ActionDBAccessor

Mark the task as to have timed out

Specified by:

timeoutHostRole in interface ActionDBAccessor

getStagesInProgress

public List<Stage> getStagesInProgress()

Description copied from interface: ActionDBAccessor

Returns all the pending stages, including queued and not-queued. A stage is considered in progress if it is in progress for any host.

Specified by:

getStagesInProgress in interface ActionDBAccessor

persistActions

public void persistActions(Request request)

Description copied from interface: ActionDBAccessor

Persists all tasks for a given request

Specified by:

persistActions in interface ActionDBAccessor

Parameters:

request - request object

startRequest

public void startRequest(long requestId)

Specified by:

startRequest in interface ActionDBAccessor

endRequest

public void endRequest(long requestId)

Specified by:

endRequest in interface ActionDBAccessor

endRequestIfCompleted

public void endRequestIfCompleted(long requestId)

setSourceScheduleForRequest

public void setSourceScheduleForRequest(long requestId,
                                        long scheduleId)

Description copied from interface: ActionDBAccessor

Updates request with link to source schedule

Specified by:

setSourceScheduleForRequest in interface ActionDBAccessor

updateHostRoleStates

public void updateHostRoleStates(Collection<CommandReport> reports)

Description copied from interface: ActionDBAccessor

Update tasks according to command reports

Specified by:

updateHostRoleStates in interface ActionDBAccessor

updateHostRoleState

public void updateHostRoleState(String hostname,
                                long requestId,
                                long stageId,
                                String role,
                                CommandReport report)

Description copied from interface: ActionDBAccessor

For the given host, update all the tasks based on the command report

Specified by:

updateHostRoleState in interface ActionDBAccessor

abortHostRole

public void abortHostRole(String host,
                          long requestId,
                          long stageId,
                          String role)

Description copied from interface: ActionDBAccessor

Mark the task as to have been aborted

Specified by:

abortHostRole in interface ActionDBAccessor

abortHostRole

public void abortHostRole(String host,
                          long requestId,
                          long stageId,
                          String role,
                          String reason)

Description copied from interface: ActionDBAccessor

Mark the task as to have been aborted. Reason should be specified manually.

Specified by:

abortHostRole in interface ActionDBAccessor

getLastPersistedRequestIdWhenInitialized

public long getLastPersistedRequestIdWhenInitialized()

Description copied from interface: ActionDBAccessor

Return the last persisted Request ID as seen when the DBAccessor object was initialized. Value should remain unchanged through the lifetime of the object instance.

Specified by:

getLastPersistedRequestIdWhenInitialized in interface ActionDBAccessor

Returns:

Request Id seen at init time

hostRoleScheduled

public void hostRoleScheduled(Stage s,
                              String hostname,
                              String roleStr)

Description copied from interface: ActionDBAccessor

Updates scheduled stage.

Specified by:

hostRoleScheduled in interface ActionDBAccessor

getRequestTasks

public List<HostRoleCommand> getRequestTasks(long requestId)

Description copied from interface: ActionDBAccessor

Given a request id, get all the tasks that belong to this request

Specified by:

getRequestTasks in interface ActionDBAccessor

getAllTasksByRequestIds

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

Description copied from interface: ActionDBAccessor

Given a list of request ids, get all the tasks that belong to these requests

Specified by:

getAllTasksByRequestIds in interface ActionDBAccessor

getTasksByRequestAndTaskIds

public List<HostRoleCommand> getTasksByRequestAndTaskIds(Collection<Long> requestIds,
                                                         Collection<Long> taskIds)

Description copied from interface: ActionDBAccessor

Get a list of host role commands where the request id belongs to the input requestIds and the task id belongs to the input taskIds

Specified by:

getTasksByRequestAndTaskIds in interface ActionDBAccessor

getTasks

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

Description copied from interface: ActionDBAccessor

Given a list of task ids, get all the host role commands

Specified by:

getTasks in interface ActionDBAccessor

getStagesByHostRoleStatus

public List<Stage> getStagesByHostRoleStatus(Set<HostRoleStatus> statuses)

Description copied from interface: ActionDBAccessor

Get all stages that contain tasks with specified host role statuses

Specified by:

getStagesByHostRoleStatus in interface ActionDBAccessor

getRequestIds

public List<Long> getRequestIds()

Description copied from interface: ActionDBAccessor

Get all requests

Specified by:

getRequestIds in interface ActionDBAccessor

getTask

public HostRoleCommand getTask(long taskId)

Description copied from interface: ActionDBAccessor

Gets the host role command corresponding to the task id

Specified by:

getTask in interface ActionDBAccessor

getRequestsByStatus

public List<Long> getRequestsByStatus(RequestStatus status)

Description copied from interface: ActionDBAccessor

Gets request id of request that are in the specified status

Specified by:

getRequestsByStatus in interface ActionDBAccessor

getRequestContext

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

Description copied from interface: ActionDBAccessor

Gets request contexts associated with the list of request id

Specified by:

getRequestContext in interface ActionDBAccessor

getRequestContext

public String getRequestContext(long requestId)

Description copied from interface: ActionDBAccessor

Gets the request context associated with the request id

Specified by:

getRequestContext in interface ActionDBAccessor

getRequests

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

Description copied from interface: ActionDBAccessor

Gets request objects by ids

Specified by:

getRequests in interface ActionDBAccessor