Modifier and Type | Method and Description |
---|---|
Stage |
StageFactory.createExisting(StageEntity stageEntity) |
Stage |
StageFactory.createNew(long requestId,
String logDir,
String clusterName,
String requestContext,
String clusterHostInfo) |
Stage |
ActionManager.getAction(long requestId,
long stageId) |
Stage |
ActionDBAccessor.getStage(String actionId)
Given an action id of the form requestId-stageId, retrieve the Stage
|
Stage |
ActionDBAccessorImpl.getStage(String actionId) |
Modifier and Type | Method and Description |
---|---|
List<Stage> |
ActionManager.getActions(long requestId)
Get all actions(stages) for a request.
|
List<Stage> |
ActionDBAccessor.getAllStages(long requestId)
Get all stages associated with a single request id
|
List<Stage> |
ActionDBAccessorImpl.getAllStages(long requestId) |
List<Stage> |
ActionManager.getRequestsByHostRoleStatus(Set<HostRoleStatus> statuses) |
List<Stage> |
ActionManager.getRequestStatus(long requestId) |
Collection<Stage> |
Request.getStages() |
List<Stage> |
ActionDBAccessor.getStagesByHostRoleStatus(Set<HostRoleStatus> statuses)
Get all stages that contain tasks with specified host role statuses
|
List<Stage> |
ActionDBAccessorImpl.getStagesByHostRoleStatus(Set<HostRoleStatus> statuses) |
List<Stage> |
ActionDBAccessor.getStagesInProgress()
Returns all the pending stages, including queued and not-queued.
|
List<Stage> |
ActionDBAccessorImpl.getStagesInProgress() |
Modifier and Type | Method and Description |
---|---|
void |
Stage.addExecutionCommandWrapper(Stage origStage,
String hostname,
Role r)
This method should be used only in stage planner.
|
void |
ActionDBAccessor.hostRoleScheduled(Stage s,
String hostname,
String roleStr)
Updates scheduled stage.
|
void |
ActionDBAccessorImpl.hostRoleScheduled(Stage s,
String hostname,
String roleStr) |
Modifier and Type | Method and Description |
---|---|
Request |
RequestFactory.createNewFromStages(Collection<Stage> stages) |
Request |
RequestFactory.createNewFromStages(Collection<Stage> stages,
ExecuteActionRequest actionRequest) |
void |
ActionManager.sendActions(List<Stage> stages,
ExecuteActionRequest actionRequest) |
void |
Request.setStages(Collection<Stage> stages) |
Constructor and Description |
---|
Request(Collection<Stage> stages,
Clusters clusters) |
Request(Collection<Stage> stages,
ExecuteActionRequest actionRequest,
Clusters clusters,
com.google.gson.Gson gson) |
Modifier and Type | Method and Description |
---|---|
void |
AmbariCustomCommandExecutionHelper.addExecutionCommandsToStage(ActionExecutionContext actionExecutionContext,
Stage stage,
Map<String,String> hostLevelParams)
Other than Service_Check and Decommission all other commands are pass-through
|
void |
AmbariActionExecutionHelper.addExecutionCommandsToStage(ActionExecutionContext actionContext,
Stage stage,
Map<String,String> hostLevelParams)
Add tasks to the stage based on the requested action execution
|
void |
AmbariCustomCommandExecutionHelper.addServiceCheckAction(Stage stage,
String hostname,
String smokeTestRole,
long nowTimestamp,
String serviceName,
String componentName,
Map<String,String> actionParameters,
Map<String,String> hostLevelParams)
Creates and populates service check EXECUTION_COMMAND for host.
|
Modifier and Type | Method and Description |
---|---|
List<Stage> |
RequestStageContainer.getStages()
Get request stages.
|
Modifier and Type | Method and Description |
---|---|
void |
RequestStageContainer.addStages(List<Stage> stages)
Add stages to request.
|
Constructor and Description |
---|
RequestStageContainer(Long id,
List<Stage> stages,
RequestFactory factory,
ActionManager manager)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
List<Stage> |
RoleGraph.getStages()
Returns a list of stages that need to be executed one after another
to execute the DAG generated in the last
RoleGraph.build(Stage) call. |
Modifier and Type | Method and Description |
---|---|
void |
RoleGraph.build(Stage stage)
Given a stage builds a DAG of all execution commands within the stage.
|
Modifier and Type | Method and Description |
---|---|
static Stage |
StageUtils.getATestStage(long requestId,
long stageId,
String clusterHostInfo) |
static Stage |
StageUtils.getATestStage(long requestId,
long stageId,
String hostname,
String clusterHostInfo) |
Copyright © 2014. All rights reserved.