Modifier and Type | Method and Description |
---|---|
HostRoleCommandEntity |
HostRoleCommand.constructNewPersistenceEntity() |
Modifier and Type | Method and Description |
---|---|
Collection<HostRoleCommandEntity> |
ActionDBAccessor.abortOperation(long requestId)
Abort all outstanding operations associated with the given request.
|
Collection<HostRoleCommandEntity> |
ActionDBAccessorImpl.abortOperation(long requestId)
Abort all outstanding operations associated with the given request.
|
Modifier and Type | Method and Description |
---|---|
HostRoleCommand |
HostRoleCommandFactory.createExisting(HostRoleCommandEntity hostRoleCommandEntity)
Constructor via factory
|
HostRoleCommand |
HostRoleCommandFactoryImpl.createExisting(HostRoleCommandEntity hostRoleCommandEntity)
Constructor via factory
|
Constructor and Description |
---|
HostRoleCommand(HostRoleCommandEntity hostRoleCommandEntity,
HostDAO hostDAO,
ExecutionCommandDAO executionCommandDAO,
ExecutionCommandWrapperFactory ecwFactory) |
Modifier and Type | Method and Description |
---|---|
HostRoleCommandEntity |
UpgradeSummary.getFailedTask()
Get the failed task if it exists.
|
Modifier and Type | Method and Description |
---|---|
static Map<HostRoleStatus,Integer> |
CalculatedStatus.calculateTaskEntityStatusCounts(Collection<HostRoleCommandEntity> tasks)
Returns counts of task entities that are in various states.
|
static CalculatedStatus |
CalculatedStatus.statusFromTaskEntities(Collection<HostRoleCommandEntity> tasks,
boolean skippable)
Factory method to create a calculated status.
|
Constructor and Description |
---|
UpgradeSummary(HostRoleCommandEntity hrc) |
UpgradeSummary(String displayText,
Long requestId,
Long stageId,
Long taskId,
String hostName,
HostRoleCommandEntity failedTask) |
Constructor and Description |
---|
RequestUpdateEvent(RequestEntity requestEntity,
HostRoleCommandDAO hostRoleCommandDAO,
TopologyManager topologyManager,
String clusterName,
List<HostRoleCommandEntity> hostRoleCommandEntities) |
Modifier and Type | Method and Description |
---|---|
HostRoleCommandEntity |
HostRoleCommandDAO.findByPK(long taskId) |
HostRoleCommandEntity |
HostRoleCommandDAO.findMostRecentFailure(Long requestId)
During Rolling and Express Upgrade, want to bubble up the error of the most recent failure, i.e., greatest
task id, assuming that there are no other completed tasks after it.
|
HostRoleCommandEntity |
HostRoleCommandDAO.merge(HostRoleCommandEntity entity) |
HostRoleCommandEntity |
HostRoleCommandDAO.mergeWithoutPublishEvent(HostRoleCommandEntity entity) |
Modifier and Type | Method and Description |
---|---|
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findAll() |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findAll(Request request,
Predicate predicate)
Finds all
HostRoleCommandEntity that match the provided predicate. |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findByHostId(Long hostId) |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findByHostRole(String hostName,
long requestId,
long stageId,
String role) |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findByPKs(Collection<Long> taskIds) |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findByRequest(long requestId) |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findByRequest(long requestId,
boolean refreshHint) |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findByRequestAndTaskIds(Collection<Long> requestIds,
Collection<Long> taskIds) |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findByRequestIdAndStatuses(Long requestId,
Collection<HostRoleStatus> statuses) |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findByRequestIds(Collection<Long> requestIds) |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findByStatus(Collection<HostRoleStatus> statuses)
Gets the commands in a particular status.
|
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<HostRoleCommandEntity> |
HostRoleCommandDAO.findSortedCommandsByRequestIdAndCustomCommandName(Long requestId,
String customCommandName) |
Map<String,List<HostRoleCommandEntity>> |
HostRoleCommandDAO.findSortedCommandsByStage(StageEntity stageEntity) |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findSortedCommandsByStageAndHost(StageEntity stageEntity,
HostEntity hostEntity) |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.mergeAll(Collection<HostRoleCommandEntity> entities) |
Modifier and Type | Method and Description |
---|---|
void |
HostRoleCommandDAO.create(HostRoleCommandEntity entity) |
protected void |
HostRoleCommandDAO.invalidateHostRoleCommandStatusSummaryCache(HostRoleCommandEntity hostRoleCommandEntity)
Invalidates those entries in host role command status cache which are
dependent on the passed
HostRoleCommandEntity entity. |
HostRoleCommandEntity |
HostRoleCommandDAO.merge(HostRoleCommandEntity entity) |
HostRoleCommandEntity |
HostRoleCommandDAO.mergeWithoutPublishEvent(HostRoleCommandEntity entity) |
void |
HostRoleCommandDAO.remove(HostRoleCommandEntity entity) |
Modifier and Type | Method and Description |
---|---|
List<HostRoleCommand> |
HostRoleCommandDAO.getHostRoleCommands(Collection<HostRoleCommandEntity> entities) |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.mergeAll(Collection<HostRoleCommandEntity> entities) |
Modifier and Type | Field and Description |
---|---|
static javax.persistence.metamodel.SingularAttribute<HostRoleCommandEntity,Short> |
HostRoleCommandEntity_.attemptCount |
static javax.persistence.metamodel.SingularAttribute<HostRoleCommandEntity,String> |
HostRoleCommandEntity_.commandDetail |
static javax.persistence.metamodel.SingularAttribute<HostRoleCommandEntity,String> |
HostRoleCommandEntity_.customCommandName |
static javax.persistence.metamodel.SingularAttribute<HostRoleCommandEntity,Long> |
HostRoleCommandEntity_.endTime |
static javax.persistence.metamodel.SingularAttribute<HostRoleCommandEntity,String> |
HostRoleCommandEntity_.errorLog |
static javax.persistence.metamodel.SingularAttribute<HostRoleCommandEntity,String> |
HostRoleCommandEntity_.event |
static javax.persistence.metamodel.SingularAttribute<HostRoleCommandEntity,Integer> |
HostRoleCommandEntity_.exitcode |
static javax.persistence.metamodel.SingularAttribute<HostRoleCommandEntity,HostEntity> |
HostRoleCommandEntity_.host |
static javax.persistence.metamodel.SingularAttribute<HostRoleCommandEntity,Long> |
HostRoleCommandEntity_.hostId |
static javax.persistence.metamodel.SingularAttribute<HostRoleCommandEntity,Long> |
HostRoleCommandEntity_.lastAttemptTime |
static javax.persistence.metamodel.SingularAttribute<HostRoleCommandEntity,String> |
HostRoleCommandEntity_.outputLog |
static javax.persistence.metamodel.SingularAttribute<HostRoleCommandEntity,Long> |
HostRoleCommandEntity_.requestId |
static javax.persistence.metamodel.SingularAttribute<HostRoleCommandEntity,String> |
HostRoleCommandEntity_.role |
static javax.persistence.metamodel.SingularAttribute<HostRoleCommandEntity,String> |
HostRoleCommandEntity_.roleCommand |
static javax.persistence.metamodel.SingularAttribute<HostRoleCommandEntity,Long> |
HostRoleCommandEntity_.stageId |
static javax.persistence.metamodel.SingularAttribute<HostRoleCommandEntity,Long> |
HostRoleCommandEntity_.startTime |
static javax.persistence.metamodel.SingularAttribute<HostRoleCommandEntity,String> |
HostRoleCommandEntity_.status |
static javax.persistence.metamodel.SingularAttribute<HostRoleCommandEntity,byte[]> |
HostRoleCommandEntity_.stdError |
static javax.persistence.metamodel.SingularAttribute<HostRoleCommandEntity,byte[]> |
HostRoleCommandEntity_.stdOut |
static javax.persistence.metamodel.SingularAttribute<HostRoleCommandEntity,byte[]> |
HostRoleCommandEntity_.structuredOut |
static javax.persistence.metamodel.SingularAttribute<HostRoleCommandEntity,Long> |
HostRoleCommandEntity_.taskId |
Modifier and Type | Method and Description |
---|---|
HostRoleCommandEntity |
ExecutionCommandEntity.getHostRoleCommand() |
HostRoleCommandEntity |
TopologyLogicalTaskEntity.getHostRoleCommandEntity() |
Modifier and Type | Method and Description |
---|---|
Collection<HostRoleCommandEntity> |
HostEntity.getHostRoleCommandEntities() |
Collection<HostRoleCommandEntity> |
StageEntity.getHostRoleCommands() |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionCommandEntity.setHostRoleCommand(HostRoleCommandEntity hostRoleCommandByTaskId) |
void |
TopologyLogicalTaskEntity.setHostRoleCommandEntity(HostRoleCommandEntity hostRoleCommandEntity) |
Modifier and Type | Method and Description |
---|---|
void |
HostEntity.setHostRoleCommandEntities(Collection<HostRoleCommandEntity> hostRoleCommandEntities) |
void |
StageEntity.setHostRoleCommands(Collection<HostRoleCommandEntity> hostRoleCommands) |
Modifier and Type | Method and Description |
---|---|
Collection<HostRoleCommandEntity> |
HostRequest.getTaskEntities() |
Copyright © 2022 Apache Software Foundation. All rights reserved.