| Package | Description |
|---|---|
| org.apache.ambari.server.events.listeners.alerts | |
| org.apache.ambari.server.orm.dao |
| Modifier and Type | Method and Description |
|---|---|
void |
AlertReceivedListener.onAlertEvent(AlertReceivedEvent event)
Adds an alert.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ConfigGroupDAO |
| Modifier and Type | Method and Description |
|---|---|
PrincipalTypeEntity |
PrincipalTypeDAO.ensurePrincipalTypeCreated(int principalType)
Creates and returns principal type if it wasn't persisted yet.
|
boolean |
KerberosKeytabDAO.exists(KerberosKeytabEntity kerberosKeytabEntity) |
boolean |
KerberosKeytabPrincipalDAO.exists(Long hostId,
String keytabPath,
String principalName) |
boolean |
PrivilegeDAO.exists(PrincipalEntity principalEntity,
ResourceEntity resourceEntity,
PermissionEntity permissionEntity)
Determine whether or not the privilege entity exists defined by the given principal, resource and
permission exists.
|
boolean |
KerberosKeytabDAO.exists(String keytabPath) |
boolean |
KerberosPrincipalDAO.exists(String principalName)
Tests the given principal name to see if it already exists.
|
List<ExtensionLinkEntity> |
ExtensionLinkDAO.find(ExtensionLinkRequest request)
Gets the extension links that match the specified stack name and version.
|
ServiceConfigEntity |
ServiceConfigDAO.find(Long serviceConfigId) |
StackEntity |
StackDAO.find(StackId stackId)
Gets the stack that matches the specified stack ID by name and version.
|
KerberosKeytabEntity |
KerberosKeytabDAO.find(String keytabPath) |
KerberosPrincipalEntity |
KerberosPrincipalDAO.find(String principalName)
Find a KerberosPrincipalEntity with the given principal name.
|
StackEntity |
StackDAO.find(String stackName,
String stackVersion)
Gets the stack that matches the specified name and version.
|
ExtensionEntity |
ExtensionDAO.find(String extensionName,
String extensionVersion)
Gets the extension that matches the specified name and version.
|
List<AlertDefinitionEntity> |
AlertDefinitionDAO.findAgentScoped(long clusterId)
Gets all alert definitions that are not bound to a particular service.
|
Map<Long,HostRoleCommandStatusSummaryDTO> |
HostRoleCommandDAO.findAggregateCounts(Long requestId)
Finds the counts of tasks for a request and groups them by stage id.
|
AlertSummaryDTO |
AlertsDAO.findAggregateCounts(long clusterId,
String alertName)
Finds the aggregate counts for an alert name, across all hosts.
|
List<ConfigGroupConfigMappingEntity> |
ConfigGroupConfigMappingDAO.findAll() |
List<PrivilegeEntity> |
PrivilegeDAO.findAll()
Find all privileges.
|
List<TopologyHostTaskEntity> |
TopologyHostTaskDAO.findAll() |
List<RequestOperationLevelEntity> |
RequestOperationLevelDAO.findAll() |
List<KerberosDescriptorEntity> |
KerberosDescriptorDAO.findAll()
Find all kerberos descriptors.
|
List<BlueprintEntity> |
BlueprintDAO.findAll()
Find all blueprints.
|
List<AlertHistoryEntity> |
AlertsDAO.findAll()
Gets all alerts stored in the database across all clusters.
|
List<StageEntity> |
StageDAO.findAll() |
List<PrincipalEntity> |
PrincipalDAO.findAll()
Find all principals.
|
Collection<MetainfoEntity> |
MetainfoDAO.findAll() |
List<StackEntity> |
StackDAO.findAll()
Gets all of the defined stacks.
|
List<SettingEntity> |
SettingDAO.findAll()
Find all settings.
|
List<TopologyRequestEntity> |
TopologyRequestDAO.findAll() |
List<ServiceComponentDesiredStateEntity> |
ServiceComponentDesiredStateDAO.findAll() |
List<AlertDefinitionEntity> |
AlertDefinitionDAO.findAll()
Gets all alert definitions stored in the database.
|
List<UpgradeEntity> |
UpgradeDAO.findAll()
Get all items.
|
List<RemoteAmbariClusterEntity> |
RemoteAmbariClusterDAO.findAll()
Find all view instances.
|
List<GroupEntity> |
GroupDAO.findAll() |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findAll() |
List<ViewEntity> |
ViewDAO.findAll()
Find all views.
|
List<ConfigGroupHostMappingEntity> |
ConfigGroupHostMappingDAO.findAll() |
List<RequestEntity> |
RequestDAO.findAll() |
List<ExtensionLinkEntity> |
ExtensionLinkDAO.findAll()
Gets all of the defined extension links.
|
List<TopologyHostRequestEntity> |
TopologyHostRequestDAO.findAll() |
List<ClusterEntity> |
ClusterDAO.findAll() |
List<PrincipalTypeEntity> |
PrincipalTypeDAO.findAll()
Find all principal types.
|
List<RequestScheduleBatchRequestEntity> |
RequestScheduleBatchRequestDAO.findAll() |
List<ServiceConfigEntity> |
ServiceConfigDAO.findAll()
Get all service configs
|
List<RequestScheduleEntity> |
RequestScheduleDAO.findAll() |
List<HostEntity> |
HostDAO.findAll() |
List<ResourceEntity> |
ResourceDAO.findAll()
Find all resources.
|
List<TopologyLogicalTaskEntity> |
TopologyLogicalTaskDAO.findAll() |
List<ExecutionCommandEntity> |
ExecutionCommandDAO.findAll() |
List<TopologyHostGroupEntity> |
TopologyHostGroupDAO.findAll() |
List<ServiceDesiredStateEntity> |
ServiceDesiredStateDAO.findAll() |
List<RoleSuccessCriteriaEntity> |
RoleSuccessCriteriaDAO.findAll() |
List<TopologyHostInfoEntity> |
TopologyHostInfoDAO.findAll() |
List<UserAuthenticationEntity> |
UserAuthenticationDAO.findAll() |
List<KerberosKeytabEntity> |
KerberosKeytabDAO.findAll() |
List<HostComponentDesiredStateEntity> |
HostComponentDesiredStateDAO.findAll() |
List<WidgetEntity> |
WidgetDAO.findAll() |
List<RoleAuthorizationEntity> |
RoleAuthorizationDAO.findAll()
Find all authorization entities.
|
List<ExtensionEntity> |
ExtensionDAO.findAll()
Gets all of the defined extensions.
|
List<KerberosKeytabPrincipalEntity> |
KerberosKeytabPrincipalDAO.findAll() |
List<HostConfigMappingEntity> |
HostConfigMappingDAO.findAll() |
List<UserEntity> |
UserDAO.findAll() |
Collection<KeyValueEntity> |
KeyValueDAO.findAll() |
List<ClusterStateEntity> |
ClusterStateDAO.findAll() |
List<E> |
CrudDAO.findAll()
Retrieves all entities.
|
List<ConfigGroupEntity> |
ConfigGroupDAO.findAll() |
List<ClusterServiceEntity> |
ClusterServiceDAO.findAll() |
List<TopologyLogicalRequestEntity> |
TopologyLogicalRequestDAO.findAll() |
List<PermissionEntity> |
PermissionDAO.findAll()
Find all permission entities.
|
List<HostStateEntity> |
HostStateDAO.findAll() |
List<KerberosPrincipalEntity> |
KerberosPrincipalDAO.findAll()
Find all kerberos principals.
|
List<HostComponentStateEntity> |
HostComponentStateDAO.findAll() |
List<WidgetLayoutEntity> |
WidgetLayoutDAO.findAll() |
List<MemberEntity> |
MemberDAO.findAll() |
List<ViewURLEntity> |
ViewURLDAO.findAll()
Find all view instances.
|
List<ViewInstanceEntity> |
ViewInstanceDAO.findAll()
Find all view instances.
|
List<ResourceTypeEntity> |
ResourceTypeDAO.findAll()
Find all resource types.
|
List<MpackEntity> |
MpackDAO.findAll()
Gets all mpacks stored in the database across all clusters.
|
List<AlertHistoryEntity> |
AlertsDAO.findAll(AlertHistoryRequest request)
Finds all
AlertHistoryEntity that match the provided
AlertHistoryRequest. |
List<AlertHistoryEntity> |
AlertsDAO.findAll(long clusterId)
Gets all alerts stored in the database for the given cluster.
|
List<AlertDefinitionEntity> |
AlertDefinitionDAO.findAll(long clusterId)
Gets all alert definitions stored in the database.
|
List<AlertHistoryEntity> |
AlertsDAO.findAll(long clusterId,
Date startDate,
Date endDate)
Gets all alerts stored in the database for the given cluster and that fall
withing the specified date range.
|
List<AlertHistoryEntity> |
AlertsDAO.findAll(long clusterId,
List<AlertState> alertStates)
Gets all alerts stored in the database for the given cluster that have one
of the specified alert states.
|
List<StageEntity> |
StageDAO.findAll(Request request,
Predicate predicate)
Finds all
StageEntity that match the provided
Predicate. |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findAll(Request request,
Predicate predicate)
Finds all
HostRoleCommandEntity that match the provided predicate. |
List<PrivilegeEntity> |
PrivilegeDAO.findAllByPrincipal(List<PrincipalEntity> principalList)
Find the privileges entities for the given list of principals
|
List<ConfigGroupEntity> |
ConfigGroupDAO.findAllByTag(String tag)
Find config groups by service name and so on
|
List<AlertDefinitionEntity> |
AlertDefinitionDAO.findAllEnabled(long clusterId)
Gets all enabled alert definitions stored in the database for the specified
cluster.
|
List<AlertTargetEntity> |
AlertDispatchDAO.findAllGlobalTargets()
Gets all global alert targets stored in the database.
|
List<AlertGroupEntity> |
AlertDispatchDAO.findAllGroups()
Gets all alert groups stored in the database across all clusters.
|
List<AlertGroupEntity> |
AlertDispatchDAO.findAllGroups(long clusterId)
Gets all alert groups stored in the database for the specified cluster.
|
List<MemberEntity> |
MemberDAO.findAllMembersByUser(UserEntity userEntity) |
List<AlertNoticeEntity> |
AlertDispatchDAO.findAllNotices()
Gets all alert notifications stored in the database.
|
List<AlertNoticeEntity> |
AlertDispatchDAO.findAllNotices(AlertNoticeRequest request)
Gets all alert notifications stored in the database that match the given
predicate, pagination, and sorting.
|
List<TopologyRequestEntity> |
TopologyRequestDAO.findAllProvisionRequests() |
List<Long> |
RequestDAO.findAllRequestIds(int limit,
boolean ascending) |
List<Long> |
RequestDAO.findAllRequestIds(int limit,
boolean sortAscending,
Long clusterId)
Retrieves from the database for a cluster, or specifically for non-cluster requests.
|
List<RequestResourceFilterEntity> |
RequestDAO.findAllResourceFilters() |
List<AlertTargetEntity> |
AlertDispatchDAO.findAllTargets()
Gets all alert targets stored in the database.
|
PermissionEntity |
PermissionDAO.findAmbariAdminPermission()
Find AMBARI.ADMINISTRATOR permission.
|
StageEntity |
StageDAO.findByActionId(String actionId) |
List<AmbariConfigurationEntity> |
AmbariConfigurationDAO.findByCategory(String categoryName)
Returns the Ambari configuration properties with the requested category name from the database.
|
List<WidgetEntity> |
WidgetDAO.findByCluster(long clusterId) |
List<WidgetLayoutEntity> |
WidgetLayoutDAO.findByCluster(long clusterId) |
List<HostVersionEntity> |
HostVersionDAO.findByCluster(String clusterName)
Retrieve all of the cluster versions for the given cluster name.
|
List<HostVersionEntity> |
HostVersionDAO.findByClusterAndHost(String clusterName,
String hostName)
Retrieve all of the host versions for the given cluster name and host name.
|
ClusterServiceEntity |
ClusterServiceDAO.findByClusterAndServiceNames(String clusterName,
String serviceName) |
List<HostVersionEntity> |
HostVersionDAO.findByClusterAndState(String clusterName,
RepositoryVersionState state)
Retrieve all of the host versions for the given cluster name, and state.
|
List<HostVersionEntity> |
HostVersionDAO.findByClusterHostAndState(String clusterName,
String hostName,
RepositoryVersionState state)
Retrieve all of the host versions for the given cluster name, host name, and state.
|
List<TopologyRequestEntity> |
TopologyRequestDAO.findByClusterId(long clusterId) |
List<HostVersionEntity> |
HostVersionDAO.findByClusterStackAndVersion(String clusterName,
StackId stackId,
String version)
Retrieve all of the host versions for the given cluster name, stack name,
and stack version.
|
HostVersionEntity |
HostVersionDAO.findByClusterStackVersionAndHost(String clusterName,
StackId stackId,
String version,
String hostName)
Retrieve the single host version for the given cluster, stack name, stack
version, and host name.
|
List<ViewEntity> |
ViewDAO.findByCommonName(String viewCommonName)
Find a view with a given common name.
|
RepositoryVersionEntity |
RepositoryVersionDAO.findByDisplayName(String displayName)
Retrieves repository version by name.
|
List<ExtensionLinkEntity> |
ExtensionLinkDAO.findByExtension(String extensionName,
String extensionVersion)
Gets the extension links that match the specified extension name and version.
|
List<KerberosKeytabPrincipalEntity> |
KerberosKeytabPrincipalDAO.findByFilter(KerberosKeytabPrincipalDAO.KerberosKeytabPrincipalFilter filter) |
List<ArtifactEntity> |
ArtifactDAO.findByForeignKeys(TreeMap<String,String> foreignKeys)
Find all artifacts for the specified foreign keys.
|
List<ConfigGroupConfigMappingEntity> |
ConfigGroupConfigMappingDAO.findByGroup(Long groupId) |
Set<ConfigGroupHostMapping> |
ConfigGroupHostMappingDAO.findByGroup(Long groupId) |
List<TopologyHostInfoEntity> |
TopologyHostInfoDAO.findByHost(HostEntity host) |
List<KerberosKeytabPrincipalEntity> |
KerberosKeytabPrincipalDAO.findByHost(Long hostId) |
List<HostVersionEntity> |
HostVersionDAO.findByHost(String hostName)
Retrieve all of the host versions for the given host name across all clusters.
|
List<HostComponentStateEntity> |
HostComponentStateDAO.findByHost(String hostName)
Retrieve all of the Host Component States for the given host.
|
List<KerberosKeytabPrincipalEntity> |
KerberosKeytabPrincipalDAO.findByHostAndKeytab(Long hostId,
String keytabPath) |
List<RequestOperationLevelEntity> |
RequestOperationLevelDAO.findByHostId(Long hostId) |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findByHostId(Long hostId) |
Set<ConfigGroupHostMapping> |
ConfigGroupHostMappingDAO.findByHostId(Long hostId) |
HostStateEntity |
HostStateDAO.findByHostId(Long hostId) |
KerberosKeytabPrincipalEntity |
KerberosKeytabPrincipalDAO.findByHostKeytabAndPrincipal(Long hostId,
String keytabPath,
String principalName) |
Collection<TopologyHostTaskEntity> |
TopologyHostTaskDAO.findByHostRequest(Long id) |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findByHostRole(String hostName,
long requestId,
long stageId,
String role) |
List<HostComponentDesiredStateEntity> |
HostComponentDesiredStateDAO.findByHostsAndCluster(Collection<Long> hostIds,
Long clusterId) |
PrivilegeEntity |
PrivilegeDAO.findById(Integer id)
Find a privilege with the given id.
|
PrincipalTypeEntity |
PrincipalTypeDAO.findById(Integer id)
Find a principal type with the given id.
|
PermissionEntity |
PermissionDAO.findById(Integer id)
Find a permission entity with the given id.
|
ResourceTypeEntity |
ResourceTypeDAO.findById(Integer id)
Find a resource type with the given id.
|
AlertHistoryEntity |
AlertsDAO.findById(long alertId)
Gets an alert with the specified ID.
|
StackEntity |
StackDAO.findById(long stackId)
Gets a stack with the specified ID.
|
ServiceComponentDesiredStateEntity |
ServiceComponentDesiredStateDAO.findById(long id)
Gets a
ServiceComponentDesiredStateEntity by its PK ID. |
AlertDefinitionEntity |
AlertDefinitionDAO.findById(long definitionId)
Gets an alert definition with the specified ID.
|
ExtensionLinkEntity |
ExtensionLinkDAO.findById(long linkId)
Gets an extension link with the specified ID.
|
ClusterEntity |
ClusterDAO.findById(long id)
Looks for Cluster by ID
|
HostEntity |
HostDAO.findById(long hostId)
Looks for Host by ID
|
TopologyHostInfoEntity |
TopologyHostInfoDAO.findById(long hostInfoId)
Looks for TopologyHostInfo by ID
|
HostComponentDesiredStateEntity |
HostComponentDesiredStateDAO.findById(long id) |
ExtensionEntity |
ExtensionDAO.findById(long extensionId)
Gets a extension with the specified ID.
|
HostComponentStateEntity |
HostComponentStateDAO.findById(long id) |
MpackEntity |
MpackDAO.findById(long id)
Gets an mpack with the specified ID.
|
TopologyHostTaskEntity |
TopologyHostTaskDAO.findById(Long id) |
PrincipalEntity |
PrincipalDAO.findById(Long id)
Find a principal with the given id.
|
TopologyRequestEntity |
TopologyRequestDAO.findById(Long id) |
RemoteAmbariClusterEntity |
RemoteAmbariClusterDAO.findById(Long clusterId)
Find Cluster by Id
|
TopologyHostRequestEntity |
TopologyHostRequestDAO.findById(Long id) |
RequestScheduleEntity |
RequestScheduleDAO.findById(Long id) |
ResourceEntity |
ResourceDAO.findById(Long id)
Find a resource with the given id.
|
TopologyLogicalTaskEntity |
TopologyLogicalTaskDAO.findById(Long id) |
TopologyHostGroupEntity |
TopologyHostGroupDAO.findById(Long id) |
WidgetEntity |
WidgetDAO.findById(Long id) |
ConfigGroupEntity |
ConfigGroupDAO.findById(Long id)
Find config group by its id
|
TopologyLogicalRequestEntity |
TopologyLogicalRequestDAO.findById(Long id) |
WidgetLayoutEntity |
WidgetLayoutDAO.findById(Long id) |
RoleAuthorizationEntity |
RoleAuthorizationDAO.findById(String id)
Find a authorization entity with the given id.
|
List<AlertDefinitionEntity> |
AlertDefinitionDAO.findByIds(List<Long> definitionIds)
Gets all of the alert definitions for the list of IDs given.
|
List<HostComponentDesiredStateEntity> |
HostComponentDesiredStateDAO.findByIndex(Long clusterId,
String serviceName,
String componentName)
Retrieve the single Host Component Desired State for the given unique cluster, service, component, and host.
|
HostComponentDesiredStateEntity |
HostComponentDesiredStateDAO.findByIndex(Long clusterId,
String serviceName,
String componentName,
Long hostId)
Retrieve the single Host Component Desired State for the given unique cluster, service, component, and host.
|
HostComponentStateEntity |
HostComponentStateDAO.findByIndex(Long clusterId,
String serviceName,
String componentName,
Long hostId)
Retrieve the single Host Component State for the given unique cluster,
service, component, and host.
|
MetainfoEntity |
MetainfoDAO.findByKey(String key) |
KeyValueEntity |
KeyValueDAO.findByKey(String key) |
KerberosKeytabPrincipalEntity |
KerberosKeytabPrincipalDAO.findByKeytabAndPrincipalNullHost(String keytabPath,
String principal) |
AlertDefinitionEntity |
AlertDefinitionDAO.findByName(long clusterId,
String definitionName)
Gets an alert definition with the specified name.
|
ServiceComponentDesiredStateEntity |
ServiceComponentDesiredStateDAO.findByName(long clusterId,
String serviceName,
String componentName)
Finds a
ServiceComponentDesiredStateEntity by a combination of
cluster, service, and component. |
List<WidgetLayoutEntity> |
WidgetLayoutDAO.findByName(Long clusterId,
String layoutName,
String userName) |
List<WidgetEntity> |
WidgetDAO.findByName(Long clusterId,
String widgetName,
String author,
String defaultSectionName) |
KerberosDescriptorEntity |
KerberosDescriptorDAO.findByName(String kerberosDescriptorName) |
BlueprintEntity |
BlueprintDAO.findByName(String blueprint_name)
Find a blueprint with a given name.
|
List<ArtifactEntity> |
ArtifactDAO.findByName(String artifactName)
Find all artifacts for the specified artifact name.
|
SettingEntity |
SettingDAO.findByName(String name)
Find a setting with the given name.
|
RemoteAmbariClusterEntity |
RemoteAmbariClusterDAO.findByName(String clusterName)
Find Cluster by name
|
ViewEntity |
ViewDAO.findByName(String viewName)
Find a view with a given name.
|
ClusterEntity |
ClusterDAO.findByName(String clusterName) |
PrincipalTypeEntity |
PrincipalTypeDAO.findByName(String name)
Find a principal type entity with the given name.
|
HostEntity |
HostDAO.findByName(String hostName) |
ConfigGroupEntity |
ConfigGroupDAO.findByName(String groupName)
Find config group by its unique name
|
PermissionEntity |
PermissionDAO.findByName(String name)
Find a permission entity with the given name.
|
com.google.common.base.Optional<ViewURLEntity> |
ViewURLDAO.findByName(String urlName)
Find URL by name
|
ResourceTypeEntity |
ResourceTypeDAO.findByName(String name)
Find a resource type with the given name.
|
ViewInstanceEntity |
ViewInstanceDAO.findByName(String viewName,
String instanceName)
Find a view with the given names.
|
ArtifactEntity |
ArtifactDAO.findByNameAndForeignKeys(String artifactName,
TreeMap<String,String> foreignKeys)
Find an artifact with the given name and foreign keys.
|
List<ServiceComponentDesiredStateEntity> |
ServiceComponentDesiredStateDAO.findByNames(Map<Long,Map<String,List<String>>> serviceComponentDesiredStates)
Finds a
ServiceComponentDesiredStateEntity by a combination of cluster id, service and component names. |
List<MpackEntity> |
MpackDAO.findByNameVersion(String mpackName,
String mpackVersion)
Gets mpacks with specified mpack name and mpack version.
|
List<PrincipalEntity> |
PrincipalDAO.findByPermissionId(Integer id)
Find principals having specified permission.
|
ClusterServiceEntity |
ClusterServiceDAO.findByPK(ClusterServiceEntityPK clusterServiceEntityPK) |
ConfigGroupConfigMappingEntity |
ConfigGroupConfigMappingDAO.findByPK(ConfigGroupConfigMappingEntityPK configGroupConfigMappingEntityPK) |
ConfigGroupHostMappingEntity |
ConfigGroupHostMappingDAO.findByPK(ConfigGroupHostMappingEntityPK configGroupHostMappingEntityPK)
Return entity object which can be used for operations like remove
directly.
|
GroupEntity |
GroupDAO.findByPK(Integer groupPK) |
UserEntity |
UserDAO.findByPK(Integer userPK) |
MemberEntity |
MemberDAO.findByPK(Integer memberPK) |
E |
CrudDAO.findByPK(K pk)
Retrieves entity by primary key.
|
HostRoleCommandEntity |
HostRoleCommandDAO.findByPK(long taskId) |
ExecutionCommandEntity |
ExecutionCommandDAO.findByPK(long taskId) |
ClusterStateEntity |
ClusterStateDAO.findByPK(long clusterId) |
RequestEntity |
RequestDAO.findByPK(Long requestId) |
UserAuthenticationEntity |
UserAuthenticationDAO.findByPK(Long pk) |
RequestScheduleBatchRequestEntity |
RequestScheduleBatchRequestDAO.findByPk(RequestScheduleBatchRequestEntityPK batchRequestEntity) |
RoleSuccessCriteriaEntity |
RoleSuccessCriteriaDAO.findByPK(RoleSuccessCriteriaEntityPK roleSuccessCriteriaEntityPK) |
ServiceDesiredStateEntity |
ServiceDesiredStateDAO.findByPK(ServiceDesiredStateEntityPK primaryKey) |
StageEntity |
StageDAO.findByPK(StageEntityPK stageEntityPK) |
List<RequestEntity> |
RequestDAO.findByPks(Collection<Long> requestIds) |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findByPKs(Collection<Long> taskIds) |
List<RequestEntity> |
RequestDAO.findByPks(Collection<Long> requestIds,
boolean refreshHint)
Given a collection of request ids, load the corresponding entities
|
List<KerberosKeytabPrincipalEntity> |
KerberosKeytabPrincipalDAO.findByPrincipal(String principal) |
List<KerberosKeytabEntity> |
KerberosKeytabDAO.findByPrincipalAndHost(String principalName,
Long hostId) |
List<KerberosKeytabEntity> |
KerberosKeytabDAO.findByPrincipalAndNullHost(String principalName) |
List<PrincipalEntity> |
PrincipalDAO.findByPrincipalType(String name) |
List<HostVersionEntity> |
HostVersionDAO.findByRepositoryAndStates(RepositoryVersionEntity repositoryVersion,
Collection<RepositoryVersionState> states)
Gets all host version entities that are of the given states
|
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<StageEntity> |
StageDAO.findByRequestId(long requestId) |
List<StageEntity> |
StageDAO.findByRequestIdAndCommandStatuses(Long requestId,
Collection<HostRoleStatus> statuses) |
TopologyHostGroupEntity |
TopologyHostGroupDAO.findByRequestIdAndName(long topologyRequestId,
String name) |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findByRequestIdAndStatuses(Long requestId,
Collection<HostRoleStatus> statuses) |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findByRequestIds(Collection<Long> requestIds) |
ClusterEntity |
ClusterDAO.findByResourceId(long resourceId) |
ViewInstanceEntity |
ViewInstanceDAO.findByResourceId(long resourceId)
Find a view instance by given resource id.
|
List<PrivilegeEntity> |
PrivilegeDAO.findByResourceId(Long id)
Find all privileges for given resource.
|
ResourceEntity |
ResourceDAO.findByResourceTypeId(Integer id)
Find a resource with the given resource type id.
|
List<RequestScheduleBatchRequestEntity> |
RequestScheduleBatchRequestDAO.findByScheduleId(Long scheduleId) |
List<WidgetEntity> |
WidgetDAO.findByScopeOrAuthor(String author,
String scope) |
List<WidgetEntity> |
WidgetDAO.findBySectionName(String sectionName) |
List<WidgetLayoutEntity> |
WidgetLayoutDAO.findBySectionName(String sectionName) |
List<AlertDefinitionEntity> |
AlertDefinitionDAO.findByService(long clusterId,
String serviceName)
Gets all alert definitions for the given service in the specified cluster.
|
List<ServiceConfigEntity> |
ServiceConfigDAO.findByService(Long clusterId,
String serviceName) |
List<HostComponentStateEntity> |
HostComponentStateDAO.findByService(String serviceName)
Retrieve all of the Host Component States for the given service.
|
List<HostComponentStateEntity> |
HostComponentStateDAO.findByServiceAndComponent(String serviceName,
String componentName)
Retrieve all of the Host Component States for the given service and component.
|
List<HostComponentStateEntity> |
HostComponentStateDAO.findByServiceAndComponentAndNotVersion(String serviceName,
String componentName,
String version) |
ServiceConfigEntity |
ServiceConfigDAO.findByServiceAndVersion(String serviceName,
Long version) |
List<AlertDefinitionEntity> |
AlertDefinitionDAO.findByServiceComponent(long clusterId,
String serviceName,
String componentName)
Gets all alert definitions that are not bound to a particular service.
|
HostComponentDesiredStateEntity |
HostComponentDesiredStateDAO.findByServiceComponentAndHost(String serviceName,
String componentName,
String hostName)
Retrieve the single Host Component Desired State for the given unique service, component, and host.
|
HostComponentStateEntity |
HostComponentStateDAO.findByServiceComponentAndHost(String serviceName,
String componentName,
String hostName)
Retrieve the single Host Component State for the given unique service, component, and host.
|
List<RepositoryVersionEntity> |
RepositoryVersionDAO.findByServiceDesiredVersion(List<RepositoryVersionEntity> matching)
Retrieves the repo versions matching the provided ones that are currently being used
for a service.
|
List<AlertDefinitionEntity> |
AlertDefinitionDAO.findByServiceMaster(long clusterId,
Set<String> services)
Gets all alert definitions for the specified services that do not have a
component and do not belong to AGGREGATE source type.
|
List<AlertDefinitionEntity> |
AlertDefinitionDAO.findBySourceType(Long clusterId,
SourceType sourceType) |
List<RepositoryVersionEntity> |
RepositoryVersionDAO.findByStack(StackId stackId)
Retrieves repository version by stack.
|
List<ExtensionLinkEntity> |
ExtensionLinkDAO.findByStack(String stackName,
String stackVersion)
Gets the extension links that match the specified stack name and version.
|
ExtensionLinkEntity |
ExtensionLinkDAO.findByStackAndExtension(String stackName,
String stackVersion,
String extensionName,
String extensionVersion)
Gets the extension link that match the specified stack name, stack version, extension name and extension version.
|
List<ExtensionLinkEntity> |
ExtensionLinkDAO.findByStackAndExtensionName(String stackName,
String stackVersion,
String extensionName)
Gets the extension link that match the specified stack name, stack version and extension name.
|
List<RepositoryVersionEntity> |
RepositoryVersionDAO.findByStackAndType(StackId stackId,
org.apache.ambari.spi.RepositoryType type)
Retrieves repository version by stack.
|
RepositoryVersionEntity |
RepositoryVersionDAO.findByStackAndVersion(StackEntity stackEntity,
String version)
Retrieves repository version by stack.
|
RepositoryVersionEntity |
RepositoryVersionDAO.findByStackAndVersion(StackId stackId,
String version)
Retrieves repository version by stack.
|
RepositoryVersionEntity |
RepositoryVersionDAO.findByStackNameAndVersion(String stackName,
String version)
Retrieves repository version, which is unique in this stack.
|
List<HostEntity> |
HostDAO.findByStage(StageEntity stageEntity) |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findByStatus(Collection<HostRoleStatus> statuses)
Gets the commands in a particular status.
|
List<RequestScheduleEntity> |
RequestScheduleDAO.findByStatus(String status) |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findByStatusBetweenStages(long requestId,
HostRoleStatus status,
long minStageId,
long maxStageId)
Finds all the
HostRoleCommandEntitys for the given request that are
between the specified stage IDs and have the specified status. |
com.google.common.base.Optional<ViewURLEntity> |
ViewURLDAO.findBySuffix(String urlSuffix)
Find URL by suffix
|
Set<HostConfigMapping> |
HostConfigMappingDAO.findByType(long clusterId,
Long hostId,
String type) |
List<UserAuthenticationEntity> |
UserAuthenticationDAO.findByType(UserAuthenticationType authenticationType) |
List<UserAuthenticationEntity> |
UserAuthenticationDAO.findByTypeAndKey(UserAuthenticationType authenticationType,
String key) |
MemberEntity |
MemberDAO.findByUserAndGroup(String userName,
String groupName) |
RepositoryVersionEntity |
RepositoryVersionDAO.findByVersion(String repositoryVersion) |
PermissionEntity |
PermissionDAO.findClusterOperatePermission()
Find CLUSTER.ADMINISTRATOR permission.
|
PermissionEntity |
PermissionDAO.findClusterReadPermission()
Find CLUSTER.USER permission.
|
ClusterConfigEntity |
ClusterDAO.findConfig(Long configEntityPK) |
ClusterConfigEntity |
ClusterDAO.findConfig(Long clusterId,
String type,
Long version) |
ClusterConfigEntity |
ClusterDAO.findConfig(Long clusterId,
String type,
String tag) |
List<AlertCurrentEntity> |
AlertsDAO.findCurrent()
Gets the current alerts.
|
List<AlertCurrentEntity> |
AlertsDAO.findCurrentByCluster(long clusterId)
Gets the current alerts for a given cluster.
|
List<AlertCurrentEntity> |
AlertsDAO.findCurrentByDefinitionId(long definitionId)
Gets the current alerts for the specified definition ID.
|
AlertCurrentEntity |
AlertsDAO.findCurrentById(long alertId)
Gets a current alert with the specified ID.
|
List<AlertCurrentEntity> |
AlertsDAO.findCurrentByService(long clusterId,
String serviceName)
Gets the current alerts for a given service.
|
AlertSummaryDTO |
AlertsDAO.findCurrentCounts(long clusterId,
String serviceName,
String hostName)
Retrieves the summary information for a particular scope.
|
AlertHostSummaryDTO |
AlertsDAO.findCurrentHostCounts(long clusterId)
Retrieve the summary alert information for all hosts.
|
Map<String,AlertSummaryDTO> |
AlertsDAO.findCurrentPerHostCounts(long clusterId)
Retrieves the summary information for all the hosts in the provided cluster.
|
AlertGroupEntity |
AlertDispatchDAO.findDefaultServiceGroup(long clusterId,
String serviceName)
Gets the default group for the specified cluster and service.
|
ClusterConfigEntity |
ClusterDAO.findEnabledConfigByType(long clusterId,
String type)
Gets the latest config in the given cluster by type name.
|
List<StageEntity> |
StageDAO.findFirstStageByStatus(Collection<HostRoleStatus> statuses)
Finds the first stage matching any of the specified statuses for every
request.
|
AlertGroupEntity |
AlertDispatchDAO.findGroupById(long groupId)
Gets an alert group with the specified ID.
|
AlertGroupEntity |
AlertDispatchDAO.findGroupByName(long clusterId,
String groupName)
Gets an alert group with the specified name for the given cluster.
|
GroupEntity |
GroupDAO.findGroupByName(String groupName) |
GroupEntity |
GroupDAO.findGroupByNameAndType(String groupName,
GroupType groupType) |
GroupEntity |
GroupDAO.findGroupByPrincipal(PrincipalEntity principal)
Find the group entity for the given admin principal entity.
|
List<AlertGroupEntity> |
AlertDispatchDAO.findGroupsByDefinition(AlertDefinitionEntity definitionEntity)
Gets all of the
AlertGroupEntity instances that include the
specified alert definition. |
List<AlertGroupEntity> |
AlertDispatchDAO.findGroupsById(List<Long> groupIds)
Gets all of the alert groups for the list of IDs given.
|
List<GroupEntity> |
GroupDAO.findGroupsByPrincipal(List<PrincipalEntity> principalList)
Find the group entities for the given list of principals
|
Set<Long> |
TopologyHostTaskDAO.findHostRequestIdsByHostTaskIds(Set<Long> hostTaskIds) |
Set<Long> |
TopologyLogicalTaskDAO.findHostTaskIdsByPhysicalTaskIds(Set<Long> physicalTaskIds) |
List<HostVersionEntity> |
HostVersionDAO.findHostVersionByClusterAndRepository(long clusterId,
RepositoryVersionEntity repositoryVersion)
Gets all host version entities assocaited with the specified cluster and
repository.
|
HostVersionEntity |
HostVersionDAO.findHostVersionByHostAndRepository(HostEntity host,
RepositoryVersionEntity repositoryVersion)
Gets the
HostVersionEntity associted with the specified host and
repository. |
UpgradeEntity |
UpgradeDAO.findLastUpgradeForCluster(long clusterId,
Direction direction) |
UpgradeEntity |
UpgradeDAO.findLastUpgradeOrDowngradeForCluster(long clusterId) |
Long |
CrudDAO.findMaxId(String idColName)
Retrieves the maximum ID from the entities.
|
ServiceConfigEntity |
ServiceConfigDAO.findMaxVersion(Long clusterId,
String serviceName) |
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.
|
Long |
ClusterDAO.findNextConfigVersion(long clusterId,
String configType)
Gets the next version that will be created for a given
ClusterConfigEntity. |
Long |
ServiceConfigDAO.findNextServiceConfigVersion(long clusterId,
String serviceName)
Gets the next version that will be created when persisting a new
ServiceConfigEntity. |
AlertNoticeEntity |
AlertDispatchDAO.findNoticeById(long noticeId)
Gets a notification with the specified ID.
|
AlertNoticeEntity |
AlertDispatchDAO.findNoticeByUuid(String uuid)
Gets a notification with the specified UUID.
|
List<AlertNoticeEntity> |
AlertDispatchDAO.findPendingNotices()
Gets all
AlertNoticeEntity instances that are
NotificationState.PENDING and not yet dispatched. |
PermissionEntity |
PermissionDAO.findPermissionByNameAndType(String name,
ResourceTypeEntity resourceType)
Find a permission entity by name and type.
|
List<PermissionEntity> |
PermissionDAO.findPermissionsByPrincipal(List<PrincipalEntity> principalList)
Find the permission entities for the given list of principals
|
List<RepositoryVersionEntity> |
RepositoryVersionDAO.findRepositoriesWithVersionDefinitions()
Retrieves repository version when they are loaded by a version definition
file.
|
Map<Long,String> |
StageDAO.findRequestContext(List<Long> requestIds) |
String |
StageDAO.findRequestContext(long requestId) |
Set<Long> |
TopologyLogicalRequestDAO.findRequestIdsByIds(Set<Long> ids) |
ResourceEntity |
ViewInstanceDAO.findResourceForViewInstance(String viewName,
String instanceName)
Gets the associated
ResourceEntity for a given instance. |
UpgradeEntity |
UpgradeDAO.findRevertable(long clusterId)
Gets the only revertable upgrade if one exists.
|
UpgradeEntity |
UpgradeDAO.findRevertableUsingJPQL(long clusterId)
Gets the only revertable upgrade if one exists.
|
Set<HostConfigMapping> |
HostConfigMappingDAO.findSelected(long clusterId,
Long hostId) |
Set<HostConfigMapping> |
HostConfigMappingDAO.findSelectedByHosts(Collection<Long> hostIds) |
HostConfigMapping |
HostConfigMappingDAO.findSelectedByType(long clusterId,
Long hostId,
String type) |
Map<String,List<HostConfigMapping>> |
HostConfigMappingDAO.findSelectedHostsByTypes(long clusterId,
Collection<String> types) |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findSortedCommandsByRequestIdAndCustomCommandName(Long requestId,
String customCommandName) |
Map<String,List<HostRoleCommandEntity>> |
HostRoleCommandDAO.findSortedCommandsByStage(StageEntity stageEntity) |
List<HostRoleCommandEntity> |
HostRoleCommandDAO.findSortedCommandsByStageAndHost(StageEntity stageEntity,
HostEntity hostEntity) |
AlertTargetEntity |
AlertDispatchDAO.findTargetById(long targetId)
Gets an alert target with the specified ID.
|
AlertTargetEntity |
AlertDispatchDAO.findTargetByName(String targetName)
Gets an alert target with the specified name.
|
List<AlertTargetEntity> |
AlertDispatchDAO.findTargetsById(List<Long> targetIds)
Gets all of the alert targets for the list of IDs given.
|
List<Long> |
HostRoleCommandDAO.findTaskIdsByHostRoleAndStatus(String hostname,
String role,
HostRoleStatus status) |
List<Long> |
HostRoleCommandDAO.findTaskIdsByRequest(long requestId) |
List<Long> |
HostRoleCommandDAO.findTaskIdsByRequestAndTaskIds(Collection<Long> requestIds,
Collection<Long> taskIds) |
List<Long> |
HostRoleCommandDAO.findTaskIdsByRequestIds(Collection<Long> requestIds) |
List<Long> |
HostRoleCommandDAO.findTaskIdsByRoleAndStatus(String role,
HostRoleStatus status) |
List<Long> |
HostRoleCommandDAO.findTaskIdsByStage(long requestId,
long stageId) |
UpgradeEntity |
UpgradeDAO.findUpgrade(long upgradeId)
Finds a specific upgrade
|
UpgradeEntity |
UpgradeDAO.findUpgradeByRequestId(Long requestId) |
UpgradeGroupEntity |
UpgradeDAO.findUpgradeGroup(Long groupId) |
UpgradeItemEntity |
UpgradeDAO.findUpgradeItemByRequestAndStage(Long requestId,
Long stageId) |
List<UpgradeEntity> |
UpgradeDAO.findUpgrades(long clusterId) |
UserEntity |
UserDAO.findUserByName(String userName) |
UserEntity |
UserDAO.findUserByPrincipal(PrincipalEntity principal)
Find the user entity for the given admin principal entity.
|
List<UserEntity> |
UserDAO.findUsersByPrincipal(List<PrincipalEntity> principalList)
Find the user entities for the given list of admin principal entities.
|
ServiceComponentVersionEntity |
ServiceComponentDesiredStateDAO.findVersion(long clusterId,
String serviceName,
String componentName,
String version)
Gets a specific version for a component
|
List<ServiceComponentVersionEntity> |
ServiceComponentDesiredStateDAO.findVersions(long clusterId,
String serviceName,
String componentName) |
PermissionEntity |
PermissionDAO.findViewUsePermission()
Find VIEW.USER permission.
|
List<ClusterConfigEntity> |
ClusterDAO.getAllConfigurations(Long clusterId,
StackId stackId)
Get all configurations for the specified cluster and stack.
|
List<String> |
HostRoleCommandDAO.getBlockingHostsForRequest(long lowerRequestIdInclusive,
long requestId)
Gets a lists of hosts with commands in progress which occurr before the
specified request ID.
|
List<Long> |
HostRoleCommandDAO.getCompletedRequests(int maxResults,
boolean ascOrder) |
Number |
HostRoleCommandDAO.getCountByStatus(Collection<HostRoleStatus> statuses)
Gets the number of commands in a particular status.
|
List<ClusterConfigEntity> |
ClusterDAO.getEnabledConfigs(long clusterId)
Gets the latest configurations for the specified cluster.
|
List<ClusterConfigEntity> |
ClusterDAO.getEnabledConfigsByStack(long clusterId,
StackId stackId)
Gets the latest configurations for a given stack for all of the
configurations of the specified cluster.
|
List<ClusterConfigEntity> |
ClusterDAO.getEnabledConfigsByTypes(Long clusterId,
Collection<String> types) |
Map<Long,Integer> |
HostRoleCommandDAO.getHostIdToCountOfCommandsWithStatus(Collection<HostRoleStatus> statuses) |
List<String> |
HostRoleCommandDAO.getHostsWithPendingTasks(long iLowestRequestIdInProgress,
long iHighestRequestIdInProgress)
Gets a lists of hosts with commands in progress given a range of requests.
|
long |
StageDAO.getLastRequestId() |
ServiceConfigEntity |
ServiceConfigDAO.getLastServiceConfig(Long clusterId,
String serviceName) |
ServiceConfigEntity |
ServiceConfigDAO.getLastServiceConfigForServiceDefaultGroup(Long clusterId,
String serviceName)
Gets the latest service config versions of default config group for a service
|
List<ServiceConfigEntity> |
ServiceConfigDAO.getLastServiceConfigs(Long clusterId) |
List<ServiceConfigEntity> |
ServiceConfigDAO.getLastServiceConfigsForService(Long clusterId,
String serviceName)
Gets the latest service config versions of all config groups for a service
|
ServiceConfigEntity |
ServiceConfigDAO.getLastServiceConfigVersionsForGroup(Long configGroupId) |
List<ServiceConfigEntity> |
ServiceConfigDAO.getLastServiceConfigVersionsForGroups(Collection<Long> configGroupIds) |
Long |
RequestDAO.getLastStageId(long requestId) |
List<ClusterConfigEntity> |
ClusterDAO.getLatestConfigurations(long clusterId,
StackId stackId)
Gets the latest configurations for a given stack for all of the
configurations of the specified cluster.
|
List<ClusterConfigEntity> |
ClusterDAO.getLatestConfigurationsWithTypes(long clusterId,
StackId stackId,
Collection<String> configTypes)
Gets the latest configurations for a given stack with any of the given config types.
|
List<HostRoleCommandDAO.LastServiceCheckDTO> |
HostRoleCommandDAO.getLatestServiceChecksByRole(long clusterId)
Gets the most recently run service check grouped by the command's role
(which is the only way to identify the service it was for!?)
|
List<ServiceConfigEntity> |
ServiceConfigDAO.getLatestServiceConfigs(Long clusterId,
StackId stackId)
Gets the latest service configurations for the specified cluster and stack.
|
int |
AlertDispatchDAO.getNoticesCount(Predicate predicate)
Gets the total count of all
AlertNoticeEntity rows that match the
specified Predicate. |
List<Long> |
HostRoleCommandDAO.getRequestsByTaskStatus(Collection<HostRoleStatus> statuses,
int maxResults,
boolean ascOrder)
Gets requests that have tasks in any of the specified statuses.
|
List<ServiceConfigEntity> |
ServiceConfigDAO.getServiceConfigs(Long clusterId)
Get all service configs for the given cluster.
|
List<ServiceConfigEntity> |
ServiceConfigDAO.getServiceConfigsForServiceAndStack(Long clusterId,
StackId stackId,
String serviceName)
Get service configurations for the specified cluster and stack.
|
List<Long> |
ServiceConfigDAO.getServiceConfigVersionsByConfig(Long clusterId,
String configType,
Long configVersion) |
boolean |
RequestDAO.isAllTasksCompleted(long requestId) |
boolean |
ClusterDAO.isManaged(ClusterEntity entity) |
Copyright © 2022 Apache Software Foundation. All rights reserved.