Modifier and Type | Field and Description |
---|---|
static Set<HostRoleStatus> |
HostRoleStatus.FAILED_STATUSES
The
HostRoleStatus s that represent any commands which are
considered to be "Failed". |
static Set<HostRoleStatus> |
HostRoleStatus.IN_PROGRESS_STATUSES
The
HostRoleStatus s that represent any commands which are
considered to be "In Progress". |
static Set<HostRoleStatus> |
HostRoleStatus.NOT_COMPLETED_STATUSES
The
HostRoleStatus s that represent all non-completed states. |
static Set<HostRoleStatus> |
HostRoleStatus.NOT_SKIPPABLE_FAILED_STATUSES
The
HostRoleStatus s that represent any commands which are
considered to be "Failed" and next commands can not be executed. |
static List<HostRoleStatus> |
HostRoleStatus.SCHEDULED_STATES |
static Set<HostRoleStatus> |
HostRoleStatus.STACK_UPGRADE_FAILED_STATUSES
The
HostRoleStatus s that represent the current commands that failed during stack upgrade. |
Modifier and Type | Method and Description |
---|---|
HostRoleStatus |
Stage.getHostRoleStatus(String hostname,
String role) |
HostRoleStatus |
Stage.getStatus()
get current status of the stage
|
HostRoleStatus |
Request.getStatus() |
HostRoleStatus |
HostRoleCommand.getStatus() |
static HostRoleStatus |
HostRoleStatus.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static HostRoleStatus[] |
HostRoleStatus.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static List<HostRoleStatus> |
HostRoleStatus.getCompletedStates() |
Modifier and Type | Method and Description |
---|---|
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) |
void |
Stage.setHostRoleStatus(String hostname,
String role,
HostRoleStatus status) |
void |
Stage.setStatus(HostRoleStatus status)
sets status of the stage
|
void |
Request.setStatus(HostRoleStatus status) |
void |
HostRoleCommand.setStatus(HostRoleStatus status) |
Modifier and Type | Method and Description |
---|---|
boolean |
Stage.doesStageHaveHostRoleStatus(Set<HostRoleStatus> statuses) |
Modifier and Type | Method and Description |
---|---|
HostRoleStatus |
RequestRequest.getStatus() |
Modifier and Type | Method and Description |
---|---|
void |
RequestRequest.setStatus(HostRoleStatus status) |
Modifier and Type | Method and Description |
---|---|
static HostRoleStatus |
CalculatedStatus.calculateStageStatus(List<HostRoleCommand> hostRoleCommands,
Map<HostRoleStatus,Integer> counters,
Map<Role,Float> successFactors,
boolean skippable) |
static HostRoleStatus |
CalculatedStatus.calculateSummaryDisplayStatus(Map<HostRoleStatus,Integer> counters,
int total,
boolean skippable)
Calculate an overall display status based on the given status counts.
|
static HostRoleStatus |
CalculatedStatus.calculateSummaryStatus(Map<HostRoleStatus,Integer> counters,
int total,
boolean skippable)
Calculate overall status of a stage or upgrade based on the given status counts.
|
static HostRoleStatus |
CalculatedStatus.calculateSummaryStatusFromPartialSet(Map<HostRoleStatus,Integer> counters,
boolean skippable) |
protected static HostRoleStatus |
CalculatedStatus.calculateSummaryStatusOfUpgrade(Map<HostRoleStatus,Integer> counters,
int total)
Calculate overall status of an upgrade.
|
HostRoleStatus |
CalculatedStatus.getDisplayStatus()
Get the calculated display status.
|
static HostRoleStatus |
CalculatedStatus.getOverallDisplayStatusForRequest(Collection<HostRoleStatus> hostRoleStatuses)
Calculate overall display status from collection of statuses
|
static HostRoleStatus |
CalculatedStatus.getOverallStatusForRequest(Collection<HostRoleStatus> hostRoleStatuses)
Calculate overall status from collection of statuses
|
HostRoleStatus |
CalculatedStatus.getStatus()
Get the calculated status.
|
Modifier and Type | Method and Description |
---|---|
static Map<HostRoleStatus,Integer> |
CalculatedStatus.calculateStatusCounts(Collection<HostRoleStatus> hostRoleStatuses)
Returns counts of tasks that are in various states.
|
static Map<CalculatedStatus.StatusType,Map<HostRoleStatus,Integer>> |
CalculatedStatus.calculateStatusCountsForStage(Collection<TaskStatusListener.ActiveStage> stages)
Returns map for counts of stages that are in various states.
|
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.
|
static Map<HostRoleStatus,Integer> |
CalculatedStatus.calculateTaskEntityStatusCounts(Collection<HostRoleCommandEntity> tasks)
Returns counts of task entities that are in various states.
|
static Map<HostRoleStatus,Integer> |
CalculatedStatus.calculateTaskStatusCounts(Map<Long,HostRoleCommandStatusSummaryDTO> stageDto,
Set<Long> stageIds)
Return counts of task statuses.
|
Modifier and Type | Method and Description |
---|---|
protected static Set<Role> |
CalculatedStatus.getRolesOfTasks(List<HostRoleCommand> hostRoleCommands,
HostRoleStatus status)
Get all
Role any of whose tasks are in given status |
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.calculateStatusCounts(Collection<HostRoleStatus> hostRoleStatuses)
Returns counts of tasks that are in various states.
|
static HostRoleStatus |
CalculatedStatus.calculateSummaryDisplayStatus(Map<HostRoleStatus,Integer> counters,
int total,
boolean skippable)
Calculate an overall display status based on the given status counts.
|
static HostRoleStatus |
CalculatedStatus.calculateSummaryStatus(Map<HostRoleStatus,Integer> counters,
int total,
boolean skippable)
Calculate overall status of a stage or upgrade based on the given status counts.
|
static HostRoleStatus |
CalculatedStatus.calculateSummaryStatusFromPartialSet(Map<HostRoleStatus,Integer> counters,
boolean skippable) |
protected static HostRoleStatus |
CalculatedStatus.calculateSummaryStatusOfUpgrade(Map<HostRoleStatus,Integer> counters,
int total)
Calculate overall status of an upgrade.
|
static HostRoleStatus |
CalculatedStatus.getOverallDisplayStatusForRequest(Collection<HostRoleStatus> hostRoleStatuses)
Calculate overall display status from collection of statuses
|
static HostRoleStatus |
CalculatedStatus.getOverallStatusForRequest(Collection<HostRoleStatus> hostRoleStatuses)
Calculate overall status from collection of statuses
|
Modifier and Type | Method and Description |
---|---|
HostRoleStatus |
UpgradeUpdateEvent.getRequestStatus() |
HostRoleStatus |
RequestUpdateEvent.getRequestStatus() |
HostRoleStatus |
NamedTaskUpdateEvent.getStatus() |
HostRoleStatus |
RequestUpdateEvent.HostRoleCommand.getStatus() |
Modifier and Type | Method and Description |
---|---|
void |
UpgradeUpdateEvent.setRequestStatus(HostRoleStatus requestStatus) |
void |
RequestUpdateEvent.setRequestStatus(HostRoleStatus requestStatus) |
void |
NamedTaskUpdateEvent.setStatus(HostRoleStatus status) |
void |
RequestUpdateEvent.HostRoleCommand.setStatus(HostRoleStatus status) |
Constructor and Description |
---|
HostRoleCommand(Long id,
Long requestId,
HostRoleStatus status,
String hostName) |
NamedTaskUpdateEvent(Long id,
Long requestId,
String hostName,
Long endTime,
HostRoleStatus status,
String errorLog,
String outLog,
String stderr,
String stdout,
String structuredOut) |
RequestUpdateEvent(Long requestId,
HostRoleStatus requestStatus,
Set<RequestUpdateEvent.HostRoleCommand> hostRoleCommands) |
Modifier and Type | Method and Description |
---|---|
HostRoleStatus |
TaskStatusListener.ActiveRequest.getDisplayStatus() |
HostRoleStatus |
TaskStatusListener.ActiveStage.getDisplayStatus() |
HostRoleStatus |
TaskStatusListener.ActiveRequest.getStatus() |
HostRoleStatus |
TaskStatusListener.ActiveStage.getStatus() |
Modifier and Type | Method and Description |
---|---|
void |
TaskStatusListener.ActiveRequest.setDisplayStatus(HostRoleStatus displayStatus) |
void |
TaskStatusListener.ActiveStage.setDisplayStatus(HostRoleStatus displayStatus) |
void |
TaskStatusListener.ActiveRequest.setStatus(HostRoleStatus status) |
void |
TaskStatusListener.ActiveStage.setStatus(HostRoleStatus status) |
Constructor and Description |
---|
ActiveRequest(HostRoleStatus status,
HostRoleStatus displayStatus,
Set<StageEntityPK> stageEntityPks,
Long clusterId) |
ActiveStage(HostRoleStatus status,
HostRoleStatus displayStatus,
Map<Role,Float> successFactors,
Boolean skippable,
Set<Long> taskIds) |
Modifier and Type | Method and Description |
---|---|
Map<HostRoleStatus,Integer> |
HostRoleCommandStatusSummaryDTO.getCounts() |
List<HostRoleStatus> |
HostRoleCommandStatusSummaryDTO.getTaskStatuses() |
Modifier and Type | Method and Description |
---|---|
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findByStatusBetweenStages(long requestId,
HostRoleStatus status,
long minStageId,
long maxStageId)
Finds all the
HostRoleCommandEntity s for the given request that are
between the specified stage IDs and have the specified status. |
List<Long> |
HostRoleCommandDAO.findTaskIdsByHostRoleAndStatus(String hostname,
String role,
HostRoleStatus status) |
List<Long> |
HostRoleCommandDAO.findTaskIdsByRoleAndStatus(String role,
HostRoleStatus status) |
void |
StageDAO.updateStageStatus(StageEntity stage,
HostRoleStatus desiredStatus,
ActionManager actionManager)
Update the given stage entity with the desired status.
|
RequestEntity |
RequestDAO.updateStatus(long requestId,
HostRoleStatus status,
HostRoleStatus displayStatus) |
void |
StageDAO.updateStatus(StageEntityPK stageEntityPK,
HostRoleStatus status,
HostRoleStatus displayStatus) |
int |
HostRoleCommandDAO.updateStatusByRequestId(long requestId,
HostRoleStatus target,
Collection<HostRoleStatus> sources)
NB: You cannot rely on return value if batch write is enabled
|
Modifier and Type | Method and Description |
---|---|
List<StageEntity> |
StageDAO.findByRequestIdAndCommandStatuses(Long requestId,
Collection<HostRoleStatus> statuses) |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findByRequestIdAndStatuses(Long requestId,
Collection<HostRoleStatus> statuses) |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findByStatus(Collection<HostRoleStatus> statuses)
Gets the commands in a particular status.
|
List<StageEntity> |
StageDAO.findFirstStageByStatus(Collection<HostRoleStatus> statuses)
Finds the first stage matching any of the specified statuses for every
request.
|
Number |
HostRoleCommandDAO.getCountByStatus(Collection<HostRoleStatus> statuses)
Gets the number of commands in a particular status.
|
Map<Long,Integer> |
HostRoleCommandDAO.getHostIdToCountOfCommandsWithStatus(Collection<HostRoleStatus> statuses) |
List<Long> |
HostRoleCommandDAO.getRequestsByTaskStatus(Collection<HostRoleStatus> statuses,
int maxResults,
boolean ascOrder)
Gets requests that have tasks in any of the specified statuses.
|
int |
HostRoleCommandDAO.updateStatusByRequestId(long requestId,
HostRoleStatus target,
Collection<HostRoleStatus> sources)
NB: You cannot rely on return value if batch write is enabled
|
Modifier and Type | Method and Description |
---|---|
HostRoleStatus |
StageEntity.getDisplayStatus()
get display status for the stage
|
HostRoleStatus |
RequestEntity.getDisplayStatus()
get display status for the request
|
HostRoleStatus |
TopologyHostRequestEntity.getStatus() |
HostRoleStatus |
StageEntity.getStatus()
get status for the stage
|
HostRoleStatus |
RequestEntity.getStatus()
get status for the request
|
HostRoleStatus |
HostRoleCommandEntity.getStatus() |
Modifier and Type | Method and Description |
---|---|
void |
StageEntity.setDisplayStatus(HostRoleStatus displayStatus)
sets display status for the stage
|
void |
RequestEntity.setDisplayStatus(HostRoleStatus displayStatus)
sets display status for the request
|
void |
TopologyHostRequestEntity.setStatus(HostRoleStatus status) |
void |
StageEntity.setStatus(HostRoleStatus status)
sets status for the stage
|
void |
RequestEntity.setStatus(HostRoleStatus status)
sets status for the request
|
void |
HostRoleCommandEntity.setStatus(HostRoleStatus status) |
Modifier and Type | Method and Description |
---|---|
protected CommandReport |
AbstractServerAction.createCommandReport(int exitCode,
HostRoleStatus status,
String structuredOut,
String stdout,
String stderr)
Creates a CommandReport used to report back to Ambari the status of this ServerAction.
|
Modifier and Type | Method and Description |
---|---|
HostRoleStatus |
HostRequest.getStatus() |
Modifier and Type | Method and Description |
---|---|
void |
PersistedState.setHostRequestStatus(long hostRequestId,
HostRoleStatus status,
String message)
Update the status of the given host request.
|
void |
PersistedStateImpl.setHostRequestStatus(long hostRequestId,
HostRoleStatus status,
String message) |
void |
HostRequest.setStatus(HostRoleStatus status) |
Copyright © 2022 Apache Software Foundation. All rights reserved.