Modifier and Type | Method and Description |
---|---|
HostRoleCommand |
HostRoleCommandFactory.create(Host host,
Role role,
ServiceComponentHostEvent event,
RoleCommand command,
boolean retryAllowed,
boolean autoSkipFailure)
Constructor via factory.
|
HostRoleCommand |
HostRoleCommandFactoryImpl.create(Host host,
Role role,
ServiceComponentHostEvent event,
RoleCommand command,
boolean retryAllowed,
boolean autoSkipFailure)
Constructor via factory.
|
HostRoleCommand |
HostRoleCommandFactory.create(String hostName,
Role role,
ServiceComponentHostEvent event,
RoleCommand command)
Constructor via factory.
|
HostRoleCommand |
HostRoleCommandFactoryImpl.create(String hostName,
Role role,
ServiceComponentHostEvent event,
RoleCommand command)
Constructor via factory.
|
HostRoleCommand |
HostRoleCommandFactory.create(String hostName,
Role role,
ServiceComponentHostEvent event,
RoleCommand command,
boolean retryAllowed,
boolean autoSkipFailure)
Constructor via factory.
|
HostRoleCommand |
HostRoleCommandFactoryImpl.create(String hostName,
Role role,
ServiceComponentHostEvent event,
RoleCommand command,
boolean retryAllowed,
boolean autoSkipFailure)
Constructor via factory.
|
HostRoleCommand |
HostRoleCommandFactory.createExisting(HostRoleCommandEntity hostRoleCommandEntity)
Constructor via factory
|
HostRoleCommand |
HostRoleCommandFactoryImpl.createExisting(HostRoleCommandEntity hostRoleCommandEntity)
Constructor via factory
|
HostRoleCommand |
Stage.getHostRoleCommand(long taskId)
Gets the
HostRoleCommand matching the specified ID from this stage. |
HostRoleCommand |
Stage.getHostRoleCommand(String hostname,
String role) |
HostRoleCommand |
ActionDBAccessor.getTask(long taskId)
Gets the host role command corresponding to the task id
|
HostRoleCommand |
ActionDBAccessorImpl.getTask(long taskId) |
HostRoleCommand |
ActionManager.getTaskById(long taskId) |
Modifier and Type | Method and Description |
---|---|
List<HostRoleCommand> |
ActionDBAccessor.getAllTasksByRequestIds(Collection<Long> requestIds)
Given a list of request ids, get all the tasks that belong to these requests
|
List<HostRoleCommand> |
ActionDBAccessorImpl.getAllTasksByRequestIds(Collection<Long> requestIds) |
List<HostRoleCommand> |
ActionManager.getAllTasksByRequestIds(Collection<Long> requestIds) |
List<HostRoleCommand> |
Request.getCommands() |
Map<String,Map<String,HostRoleCommand>> |
Stage.getHostRoleCommands() |
List<HostRoleCommand> |
Stage.getOrderedHostRoleCommands() |
List<HostRoleCommand> |
ActionDBAccessor.getRequestTasks(long requestId)
Given a request id, get all the tasks that belong to this request
|
List<HostRoleCommand> |
ActionDBAccessorImpl.getRequestTasks(long requestId) |
List<HostRoleCommand> |
ActionManager.getRequestTasks(long requestId) |
Collection<HostRoleCommand> |
ActionDBAccessor.getTasks(Collection<Long> taskIds)
Given a list of task ids, get all the host role commands
|
List<HostRoleCommand> |
ActionDBAccessorImpl.getTasks(Collection<Long> taskIds) |
Collection<HostRoleCommand> |
ActionManager.getTasks(Collection<Long> taskIds) |
List<HostRoleCommand> |
ActionDBAccessor.getTasksByHostRoleAndStatus(String hostname,
String role,
HostRoleStatus status)
Get a List of host role commands where the host, role and status are as specified
|
List<HostRoleCommand> |
ActionDBAccessorImpl.getTasksByHostRoleAndStatus(String hostname,
String role,
HostRoleStatus status) |
List<HostRoleCommand> |
ActionDBAccessor.getTasksByRoleAndStatus(String role,
HostRoleStatus status)
Get a List of host role commands where the role and status are as specified
|
List<HostRoleCommand> |
ActionDBAccessorImpl.getTasksByRoleAndStatus(String role,
HostRoleStatus status) |
Map<Long,HostRoleCommand> |
ActionManager.getTasksMap(Collection<Long> taskIds) |
Modifier and Type | Method and Description |
---|---|
void |
ActionManager.processTaskResponse(String hostname,
List<CommandReport> reports,
Map<Long,HostRoleCommand> commands)
Persists command reports into the db
|
Constructor and Description |
---|
ShortTaskStatus(HostRoleCommand hostRoleCommand) |
Modifier and Type | Method and Description |
---|---|
protected static List<HostRoleCommand> |
CalculatedStatus.getFailedHostRoleCommands(List<HostRoleCommand> hostRoleCommands) |
protected static List<HostRoleCommand> |
CalculatedStatus.getHostRoleCommandsOfRole(List<HostRoleCommand> hostRoleCommands,
Role role) |
Modifier and Type | Method and Description |
---|---|
static HostRoleStatus |
CalculatedStatus.calculateStageStatus(List<HostRoleCommand> hostRoleCommands,
Map<HostRoleStatus,Integer> counters,
Map<Role,Float> successFactors,
boolean skippable) |
static Map<HostRoleStatus,Integer> |
CalculatedStatus.calculateStatusCountsForTasks(Collection<HostRoleCommand> hostRoleCommands)
Returns counts of tasks that are in various states.
|
static Map<HostRoleStatus,Integer> |
CalculatedStatus.calculateStatusCountsForTasks(Collection<HostRoleCommand> hostRoleCommands,
StageEntityPK stage)
Returns counts of tasks that are in various states.
|
protected static Boolean |
CalculatedStatus.didStageFailed(List<HostRoleCommand> hostRoleCommands,
Set<Role> roles,
Map<Role,Float> successFactors) |
protected static List<HostRoleCommand> |
CalculatedStatus.getFailedHostRoleCommands(List<HostRoleCommand> hostRoleCommands) |
protected static List<HostRoleCommand> |
CalculatedStatus.getHostRoleCommandsOfRole(List<HostRoleCommand> hostRoleCommands,
Role role) |
protected static Set<Role> |
CalculatedStatus.getRolesOfAbortedTasks(List<HostRoleCommand> hostRoleCommands)
Get all
Role any of whose tasks is in HostRoleStatus.ABORTED |
protected static Set<Role> |
CalculatedStatus.getRolesOfFailedTasks(List<HostRoleCommand> hostRoleCommands)
Get all
Role any of whose tasks is in HostRoleStatus.FAILED |
protected static Set<Role> |
CalculatedStatus.getRolesOfTasks(List<HostRoleCommand> hostRoleCommands,
HostRoleStatus status)
Get all
Role any of whose tasks are in given status |
protected static Set<Role> |
CalculatedStatus.getRolesOfTimedOutTasks(List<HostRoleCommand> hostRoleCommands)
Get all
Role any of whose tasks is in HostRoleStatus.TIMEDOUT |
Modifier and Type | Method and Description |
---|---|
List<HostRoleCommand> |
TaskEvent.getHostRoleCommands()
Gets hostRoleCommands that created event
|
Constructor and Description |
---|
NamedTaskUpdateEvent(HostRoleCommand hostRoleCommand) |
Constructor and Description |
---|
TaskCreateEvent(List<HostRoleCommand> hostRoleCommandList)
Constructor.
|
TaskEvent(List<HostRoleCommand> hostRoleCommands)
Constructor.
|
TaskUpdateEvent(List<HostRoleCommand> hostRoleCommandList) |
Modifier and Type | Method and Description |
---|---|
Map<Long,HostRoleCommand> |
TaskStatusListener.getActiveTasksMap() |
Modifier and Type | Method and Description |
---|---|
List<HostRoleCommand> |
HostRoleCommandDAO.getHostRoleCommands(Collection<HostRoleCommandEntity> entities) |
Modifier and Type | Method and Description |
---|---|
void |
HostRoleCommandDAO.publishTaskCreateEvent(List<HostRoleCommand> hostRoleCommands) |
void |
HostRoleCommandDAO.publishTaskUpdateEvent(List<HostRoleCommand> hostRoleCommands) |
Modifier and Type | Method and Description |
---|---|
HostRoleCommand |
AbstractServerAction.getHostRoleCommand() |
HostRoleCommand |
ServerAction.getHostRoleCommand()
Gets the HostRoleCommand property of this ServerAction.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractServerAction.setHostRoleCommand(HostRoleCommand hostRoleCommand) |
void |
ServerAction.setHostRoleCommand(HostRoleCommand hostRoleCommand)
Sets the HostRoleCommand property of this ServerAction.
|
Modifier and Type | Method and Description |
---|---|
List<Map<String,List<HostRoleCommand>>> |
RoleGraph.getOrderedHostRoleCommands(Map<String,Map<String,HostRoleCommand>> unorderedCommands)
Gets a representation of the role ordering of the specified commands
without constructing
Stage instances. |
Modifier and Type | Method and Description |
---|---|
List<Map<String,List<HostRoleCommand>>> |
RoleGraph.getOrderedHostRoleCommands(Map<String,Map<String,HostRoleCommand>> unorderedCommands)
Gets a representation of the role ordering of the specified commands
without constructing
Stage instances. |
Modifier and Type | Method and Description |
---|---|
HostRoleCommand |
AmbariContext.createAmbariTask(long taskId,
long requestId,
long stageId,
String component,
String host,
AmbariContext.TaskType type,
boolean skipFailure) |
HostRoleCommand |
AmbariContext.createAmbariTask(long requestId,
long stageId,
String component,
String host,
AmbariContext.TaskType type,
boolean skipFailure) |
HostRoleCommand |
HostRequest.getLogicalTask(long logicalTaskId) |
HostRoleCommand |
AmbariContext.getPhysicalTask(long id) |
Modifier and Type | Method and Description |
---|---|
List<HostRoleCommand> |
LogicalRequest.getCommands() |
Collection<HostRoleCommand> |
HostRequest.getLogicalTasks() |
Collection<HostRoleCommand> |
AmbariContext.getPhysicalTasks(Collection<Long> ids) |
Collection<HostRoleCommand> |
TopologyManager.getTasks(Collection<Long> requestIds) |
Collection<HostRoleCommand> |
TopologyManager.getTasks(long requestId) |
Modifier and Type | Method and Description |
---|---|
static Map<Long,HostRoleCommand> |
CommandUtils.convertToTaskIdCommandMap(Collection<HostRoleCommand> commands)
Converts a collection of commands to Map from command.taskId to command.
|
Modifier and Type | Method and Description |
---|---|
static Map<Long,HostRoleCommand> |
CommandUtils.convertToTaskIdCommandMap(Collection<HostRoleCommand> commands)
Converts a collection of commands to Map from command.taskId to command.
|
Copyright © 2022 Apache Software Foundation. All rights reserved.