Modifier and Type | Method and Description |
---|---|
Result |
Query.execute()
Execute the query.
|
Result |
QueryImpl.execute() |
protected Map<Resource,Set<Map<String,Object>>> |
QueryImpl.getJoinedResourceProperties(Set<String> propertyIds,
Resource parentResource,
String category)
Get a map of property sets keyed by the resources associated with this
query.
|
Modifier and Type | Method and Description |
---|---|
RequestStatus |
PersistenceManagerImpl.create(ResourceInstance resource,
RequestBody requestBody) |
RequestStatus |
PersistenceManager.create(ResourceInstance resource,
RequestBody requestBody)
Create resources.
|
RequestStatus |
PersistenceManagerImpl.delete(ResourceInstance resource,
RequestBody requestBody) |
RequestStatus |
PersistenceManager.delete(ResourceInstance resource,
RequestBody requestBody) |
RequestStatus |
PersistenceManagerImpl.update(ResourceInstance resource,
RequestBody requestBody) |
RequestStatus |
PersistenceManager.update(ResourceInstance resource,
RequestBody requestBody) |
Modifier and Type | Method and Description |
---|---|
protected <T> T |
AbstractResourceProvider.createResources(AbstractResourceProvider.Command<T> command)
Invoke a command against the Ambari backend to create resources and map
any
AmbariException to the types appropriate for the
ResourceProvider interface. |
RequestStatus |
ExtensionLinkResourceProvider.createResources(Request request) |
RequestStatus |
QuickLinkArtifactResourceProvider.createResources(Request request) |
RequestStatus |
InstanceResourceProvider.createResources(Request request) |
RequestStatus |
RecommendationResourceProvider.createResources(Request request) |
RequestStatus |
AlertDefinitionResourceProvider.createResources(Request request) |
RequestStatus |
HostStackVersionResourceProvider.createResources(Request request) |
RequestStatus |
ServiceConfigVersionResourceProvider.createResources(Request request) |
RequestStatus |
ActiveWidgetLayoutResourceProvider.createResources(Request request) |
RequestStatus |
AbstractAuthorizedResourceProvider.createResources(Request request)
Create the resources defined by the properties in the given request object.
|
RequestStatus |
ThemeArtifactResourceProvider.createResources(Request request) |
RequestStatus |
PermissionResourceProvider.createResources(Request request) |
RequestStatus |
WorkflowResourceProvider.createResources(Request request) |
RequestStatus |
UpgradeSummaryResourceProvider.createResources(Request request) |
RequestStatus |
ArtifactResourceProvider.createResources(Request request) |
RequestStatus |
RequestScheduleResourceProvider.createResources(Request request) |
RequestStatus |
FeedResourceProvider.createResources(Request request) |
RequestStatus |
AlertGroupResourceProvider.createResources(Request request) |
RequestStatus |
UpgradeGroupResourceProvider.createResources(Request request) |
RequestStatus |
WidgetResourceProvider.createResources(Request request) |
RequestStatus |
RepositoryResourceProvider.createResources(Request request) |
RequestStatus |
RequestResourceProvider.createResources(Request request) |
RequestStatus |
WidgetLayoutResourceProvider.createResources(Request request) |
RequestStatus |
ActionResourceProvider.createResources(Request request) |
RequestStatus |
TaskAttemptResourceProvider.createResources(Request request) |
RequestStatus |
ViewVersionResourceProvider.createResources(Request request) |
RequestStatus |
ValidationResourceProvider.createResources(Request request) |
RequestStatus |
BlueprintResourceProvider.createResources(Request request) |
RequestStatus |
ConfigurationResourceProvider.createResources(Request request) |
RequestStatus |
ReadOnlyResourceProvider.createResources(Request request) |
RequestStatus |
ClientConfigResourceProvider.createResources(Request request) |
RequestStatus |
TargetClusterResourceProvider.createResources(Request request) |
RequestStatus |
AlertHistoryResourceProvider.createResources(Request request)
Create the resources defined by the properties in the given request object.
|
RequestStatus |
AlertNoticeResourceProvider.createResources(Request request)
Create the resources defined by the properties in the given request object.
|
RequestStatus |
MpackResourceProvider.createResources(Request request) |
RequestStatus |
StackDependencyResourceProvider.createResources(Request request) |
RequestStatus |
JobResourceProvider.createResources(Request request) |
RequestStatus |
StackArtifactResourceProvider.createResources(Request request) |
RequestStatus |
UpgradeResourceProvider.createResources(Request request) |
RequestStatus |
ViewPermissionResourceProvider.createResources(Request request) |
RequestStatus |
StageResourceProvider.createResources(Request request) |
RequestStatus |
ClusterControllerImpl.createResources(Resource.Type type,
Request request) |
RequestStatus |
ConfigGroupResourceProvider.createResources(Set<ConfigGroupRequest> requests)
Create configuration group resources based on set of config group requests.
|
protected RequestStatus |
ViewResourceProvider.createResourcesAuthorized(Request request) |
protected RequestStatus |
ViewInstanceResourceProvider.createResourcesAuthorized(Request request) |
protected RequestStatus |
AlertTargetResourceProvider.createResourcesAuthorized(Request request) |
protected RequestStatus |
HostResourceProvider.createResourcesAuthorized(Request request) |
protected RequestStatus |
RepositoryVersionResourceProvider.createResourcesAuthorized(Request request) |
RequestStatus |
RootServiceComponentConfigurationResourceProvider.createResourcesAuthorized(Request request) |
protected RequestStatus |
CredentialResourceProvider.createResourcesAuthorized(Request request) |
protected RequestStatus |
GroupResourceProvider.createResourcesAuthorized(Request request) |
protected RequestStatus |
ViewURLResourceProvider.createResourcesAuthorized(Request request) |
RequestStatus |
RemoteClusterResourceProvider.createResourcesAuthorized(Request request) |
protected RequestStatus |
VersionDefinitionResourceProvider.createResourcesAuthorized(Request request) |
protected RequestStatus |
AbstractAuthorizedResourceProvider.createResourcesAuthorized(Request request)
Create the resources defined by the properties in the given request object if authorization was
granted to the authenticated user.
|
RequestStatus |
SettingResourceProvider.createResourcesAuthorized(Request request) |
protected RequestStatus |
ClusterResourceProvider.createResourcesAuthorized(Request request) |
protected RequestStatus |
HostComponentResourceProvider.createResourcesAuthorized(Request request) |
protected RequestStatus |
ComponentResourceProvider.createResourcesAuthorized(Request request) |
RequestStatus |
LdapSyncEventResourceProvider.createResourcesAuthorized(Request event) |
RequestStatus |
PrivilegeResourceProvider.createResourcesAuthorized(Request request) |
RequestStatus |
ClusterStackVersionResourceProvider.createResourcesAuthorized(Request request) |
protected RequestStatus |
MemberResourceProvider.createResourcesAuthorized(Request request) |
RequestStatus |
UserResourceProvider.createResourcesAuthorized(Request request) |
RequestStatus |
UserAuthenticationSourceResourceProvider.createResourcesAuthorized(Request request) |
protected RequestStatus |
ServiceResourceProvider.createResourcesAuthorized(Request request) |
RequestStatus |
ConfigGroupResourceProvider.createResourcesAuthorized(Request request) |
RequestStatus |
QuickLinkArtifactResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
InstanceResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
AlertDefinitionResourceProvider.deleteResources(Request request,
Predicate predicate)
Delete the resources selected by the given predicate.
|
RequestStatus |
HostStackVersionResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
ServiceConfigVersionResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
ActiveWidgetLayoutResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
AbstractAuthorizedResourceProvider.deleteResources(Request request,
Predicate predicate)
Delete the resources selected by the given predicate.
|
RequestStatus |
ThemeArtifactResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
PermissionResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
WorkflowResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
UpgradeSummaryResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
ArtifactResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
RequestScheduleResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
FeedResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
TaskResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
AlertGroupResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
UpgradeGroupResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
WidgetResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
RepositoryResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
RequestResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
WidgetLayoutResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
ActionResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
TaskAttemptResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
ViewVersionResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
BlueprintResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
ConfigurationResourceProvider.deleteResources(Request request,
Predicate predicate)
Throws an exception, as Configurations cannot be deleted.
|
RequestStatus |
ReadOnlyResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
ClientConfigResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
TargetClusterResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
AlertHistoryResourceProvider.deleteResources(Request request,
Predicate predicate)
Delete the resources selected by the given predicate.
|
RequestStatus |
AlertNoticeResourceProvider.deleteResources(Request request,
Predicate predicate)
Delete the resources selected by the given predicate.
|
RequestStatus |
StackDependencyResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
KerberosDescriptorResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
JobResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
StackArtifactResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
UpgradeResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
ViewPermissionResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
StageResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
ClusterControllerImpl.deleteResources(Resource.Type type,
Request request,
Predicate predicate) |
protected RequestStatus |
ViewResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
ViewInstanceResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
AlertTargetResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
ExtensionLinkResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
HostResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
RepositoryVersionResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
RootServiceComponentConfigurationResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
CredentialResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
GroupResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
ViewURLResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
RemoteClusterResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
VersionDefinitionResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
AbstractAuthorizedResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate)
Delete the resources selected by the given predicate if the authenticated user is authorized
to do so.
|
protected RequestStatus |
ClusterResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
HostComponentResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
ComponentResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
RequestStatus |
LdapSyncEventResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
RequestStatus |
PrivilegeResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
RequestStatus |
ClusterStackVersionResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
MemberResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
RequestStatus |
UserResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
RequestStatus |
UserAuthenticationSourceResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
MpackResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
ServiceResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
RequestStatus |
ConfigGroupResourceProvider.deleteResourcesAuthorized(Request request,
Predicate predicate) |
RequestStageContainer |
HostComponentResourceProvider.doUpdateResources(RequestStageContainer stages,
Request request,
Predicate predicate,
boolean performQueryEvaluation,
boolean useGeneratedConfigs,
boolean useClusterHostInfo)
Update resources.
|
String |
OverriddenMetricsHostProvider.getCollectorHostName(String clusterName,
MetricsServiceProvider.MetricsService service) |
String |
AbstractProviderModule.getCollectorHostName(String clusterName,
MetricsServiceProvider.MetricsService service) |
String |
OverriddenMetricsHostProvider.getCollectorPort(String clusterName,
MetricsServiceProvider.MetricsService service) |
String |
AbstractProviderModule.getCollectorPort(String clusterName,
MetricsServiceProvider.MetricsService service) |
String |
OverriddenMetricsHostProvider.getHostName(String clusterName,
String componentName) |
String |
AbstractProviderModule.getHostName(String clusterName,
String componentName) |
Iterable<Resource> |
ClusterControllerImpl.getIterable(Resource.Type type,
QueryResponse queryResponse,
Request request,
Predicate predicate,
PageRequest pageRequest,
SortRequest sortRequest) |
PageResponse |
ClusterControllerImpl.getPage(Resource.Type type,
QueryResponse queryResponse,
Request request,
Predicate predicate,
PageRequest pageRequest,
SortRequest sortRequest) |
protected Set<Map<String,Object>> |
AbstractResourceProvider.getPropertyMaps(Map<String,Object> requestPropertyMap,
Predicate givenPredicate)
Get a set of properties from the given property map and predicate.
|
protected Iterable<Resource> |
ClusterControllerImpl.getResourceIterable(Resource.Type type,
Request request,
Predicate predicate)
Get an iterable set of resources filtered by the given request and
predicate objects.
|
protected <T> T |
AbstractResourceProvider.getResources(AbstractResourceProvider.Command<T> command)
Invoke a command against the Ambari backend to get resources and map
any
AmbariException to the types appropriate for the
ResourceProvider interface. |
Set<Resource> |
ViewResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
ClusterKerberosDescriptorResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
ViewInstanceResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
AlertTargetResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
RootServiceResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
ExtensionLinkResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
UserPrivilegeResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
StackResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
QuickLinkArtifactResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
InstanceResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
OperatingSystemResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
ViewURLResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
RootServiceHostComponentResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
AlertDefinitionResourceProvider.getResources(Request request,
Predicate predicate)
Get a set of
resources based on the given request and predicate
information. |
Set<Resource> |
StackServiceResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
RemoteClusterResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
HostStackVersionResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
VersionDefinitionResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
ActiveWidgetLayoutResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
AbstractAuthorizedResourceProvider.getResources(Request request,
Predicate predicate)
Get a set of
resources based on the given request and predicate
information. |
Set<Resource> |
UserAuthorizationResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
ThemeArtifactResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
PermissionResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
WorkflowResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
UpgradeSummaryResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
CompatibleRepositoryVersionResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
ClusterResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
ArtifactResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
RequestScheduleResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
HostComponentResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
FeedResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
ComponentResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
LdapSyncEventResourceProvider.getResources(Request event,
Predicate predicate) |
Set<Resource> |
StackVersionResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
StackConfigurationDependencyResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
UpgradeItemResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
TaskResourceProvider.getResources(Request request,
Predicate predicate)
Get a set of
resources based on the given request and predicate
information. |
Set<Resource> |
AlertGroupResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
UpgradeGroupResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
ExtensionResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
WidgetResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
RepositoryResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
LoggingResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
RequestResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
WidgetLayoutResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
ActionResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
HostComponentProcessResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
StackLevelConfigurationResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
TaskAttemptResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
ViewVersionResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
BlueprintResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
HostKerberosIdentityResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
ReadOnlyResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
StackServiceComponentResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
UserResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
UserAuthenticationSourceResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
TargetClusterResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
AlertHistoryResourceProvider.getResources(Request request,
Predicate predicate)
Get a set of
resources based on the given request and predicate
information. |
Set<Resource> |
RoleAuthorizationResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
AlertResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
RootServiceComponentResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
ExtensionVersionResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
AlertNoticeResourceProvider.getResources(Request request,
Predicate predicate)
Get a set of
resources based on the given request and predicate
information. |
Set<Resource> |
StackConfigurationResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
MpackResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
StackDependencyResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
JobResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
StackArtifactResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
PreUpgradeCheckResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
UpgradeResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
GroupPrivilegeResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
ViewPermissionResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
StageResourceProvider.getResources(Request request,
Predicate predicate) |
QueryResponse |
ClusterControllerImpl.getResources(Resource.Type type,
Request request,
Predicate predicate) |
protected PageResponse |
ClusterControllerImpl.getResources(Resource.Type type,
Request request,
Predicate predicate,
PageRequest pageRequest,
SortRequest sortRequest)
Get a page of resources filtered by the given request, predicate objects and
page request.
|
protected Set<Resource> |
HostResourceProvider.getResourcesAuthorized(Request request,
Predicate predicate) |
protected Set<Resource> |
RepositoryVersionResourceProvider.getResourcesAuthorized(Request request,
Predicate predicate) |
protected Set<Resource> |
RootServiceComponentConfigurationResourceProvider.getResourcesAuthorized(Request request,
Predicate predicate) |
protected Set<Resource> |
CredentialResourceProvider.getResourcesAuthorized(Request request,
Predicate predicate) |
protected Set<Resource> |
GroupResourceProvider.getResourcesAuthorized(Request request,
Predicate predicate) |
Set<Resource> |
ServiceConfigVersionResourceProvider.getResourcesAuthorized(Request request,
Predicate predicate) |
protected Set<Resource> |
AbstractAuthorizedResourceProvider.getResourcesAuthorized(Request request,
Predicate predicate)
Get a set of
resources based on the given request and predicate
information if the authenticated user is authorized to do so. |
Set<Resource> |
PrivilegeResourceProvider.getResourcesAuthorized(Request request,
Predicate predicate) |
Set<Resource> |
ClusterStackVersionResourceProvider.getResourcesAuthorized(Request request,
Predicate predicate) |
Set<Resource> |
ConfigurationResourceProvider.getResourcesAuthorized(Request request,
Predicate predicate) |
Set<Resource> |
ClientConfigResourceProvider.getResourcesAuthorized(Request request,
Predicate predicate) |
protected Set<Resource> |
MemberResourceProvider.getResourcesAuthorized(Request request,
Predicate predicate) |
protected Set<Resource> |
ServiceResourceProvider.getResourcesAuthorized(Request request,
Predicate predicate) |
Set<Resource> |
ConfigGroupResourceProvider.getResourcesAuthorized(Request request,
Predicate predicate) |
abstract String |
HttpPropertyProvider.HttpPropertyRequest.getUrl(Cluster cluster,
String hostName)
Get the URL used to make the HTTP request.
|
String |
ResourceManagerHttpPropertyRequest.getUrl(Cluster cluster,
String hostName) |
String |
AtlasServerHttpPropertyRequest.getUrl(Cluster cluster,
String hostName) |
RequestStatusResponse |
HostResourceProvider.install(String cluster,
String hostname,
Collection<String> skipInstallForComponents,
Collection<String> dontSkipInstallForComponents,
boolean skipFailure,
boolean useClusterHostInfo) |
RequestStatusResponse |
HostComponentResourceProvider.install(String cluster,
String hostname,
Collection<String> skipInstallForComponents,
Collection<String> dontSkipInstallForComponents,
boolean skipFailure,
boolean useClusterHostInfo) |
protected boolean |
AbstractAuthorizedResourceProvider.isAuthorizedToCreateResources(org.springframework.security.core.Authentication authentication,
Request request)
Tests authorization to create resources.
|
protected boolean |
AbstractAuthorizedResourceProvider.isAuthorizedToDeleteResources(org.springframework.security.core.Authentication authentication,
Predicate predicate)
Tests authorization to delete resources.
|
protected boolean |
ClusterResourceProvider.isAuthorizedToDeleteResources(org.springframework.security.core.Authentication authentication,
Predicate predicate) |
protected boolean |
AbstractAuthorizedResourceProvider.isAuthorizedToGetResources(org.springframework.security.core.Authentication authentication,
Request request,
Predicate predicate)
Tests authorization to get resources.
|
protected boolean |
AbstractAuthorizedResourceProvider.isAuthorizedToUpdateResources(org.springframework.security.core.Authentication authentication,
Request request,
Predicate predicate)
Tests authorization to update resources
Implementations should override this method to perform a more sophisticated authorization routine.
|
boolean |
OverriddenMetricsHostProvider.isCollectorComponentLive(String clusterName,
MetricsServiceProvider.MetricsService service) |
boolean |
AbstractProviderModule.isCollectorComponentLive(String clusterName,
MetricsServiceProvider.MetricsService service) |
boolean |
OverriddenMetricsHostProvider.isCollectorHostLive(String clusterName,
MetricsServiceProvider.MetricsService service) |
boolean |
AbstractProviderModule.isCollectorHostLive(String clusterName,
MetricsServiceProvider.MetricsService service) |
protected <T> T |
AbstractResourceProvider.modifyResources(AbstractResourceProvider.Command<T> command)
Invoke a command against the Ambari backend to modify resources and map
any
AmbariException to the types appropriate for the
ResourceProvider interface. |
org.apache.ambari.server.controller.internal.RootServiceComponentConfigurationHandler.OperationResult |
AmbariServerConfigurationHandler.performOperation(String categoryName,
Map<String,String> properties,
boolean mergeExistingProperties,
String operation,
Map<String,Object> operationParameters) |
org.apache.ambari.server.controller.internal.RootServiceComponentConfigurationHandler.OperationResult |
AmbariServerLDAPConfigurationHandler.performOperation(String categoryName,
Map<String,String> properties,
boolean mergeExistingProperties,
String operation,
Map<String,Object> operationParameters) |
abstract void |
HttpPropertyProvider.HttpPropertyRequest.populateResource(Resource resource,
InputStream inputStream)
Populate the given resource from the given input stream.
|
void |
JsonHttpPropertyRequest.populateResource(Resource resource,
InputStream inputStream) |
Set<Resource> |
ClusterControllerImpl.populateResources(Resource.Type type,
Set<Resource> resources,
Request request,
Predicate predicate) |
Set<Resource> |
AlertSummaryPropertyProvider.populateResources(Set<Resource> resources,
Request request,
Predicate predicate) |
Set<Resource> |
HttpPropertyProvider.populateResources(Set<Resource> resources,
Request request,
Predicate predicate) |
Set<Resource> |
RootServiceComponentPropertyProvider.populateResources(Set<Resource> resources,
Request request,
Predicate predicate) |
Set<Resource> |
StackDefinedPropertyProvider.populateResources(Set<Resource> resources,
Request request,
Predicate predicate) |
QueryResponse |
AlertHistoryResourceProvider.queryForResources(Request request,
Predicate predicate) |
QueryResponse |
AlertResourceProvider.queryForResources(Request request,
Predicate predicate)
Query for resources that match the given predicate.
|
QueryResponse |
AlertNoticeResourceProvider.queryForResources(Request request,
Predicate predicate) |
QueryResponse |
StageResourceProvider.queryForResources(Request request,
Predicate predicate) |
RequestStatusResponse |
HostResourceProvider.start(String cluster,
String hostname) |
RequestStatusResponse |
HostComponentResourceProvider.start(String cluster,
String hostName) |
RequestStatusResponse |
HostComponentResourceProvider.start(String cluster,
String hostName,
Collection<String> installOnlyComponents,
boolean skipFailure,
boolean useClusterHostInfo) |
protected void |
ClientConfigResourceProvider.TarUtils.tarConfigFiles()
creates single compressed file from the list of existing compressed file
|
RequestStatus |
ExtensionLinkResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
StackResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
QuickLinkArtifactResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
InstanceResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
AlertDefinitionResourceProvider.updateResources(Request request,
Predicate predicate)
Update the resources selected by the given predicate with the properties
from the given request object.
|
RequestStatus |
HostStackVersionResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
ServiceConfigVersionResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
ActiveWidgetLayoutResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
AbstractAuthorizedResourceProvider.updateResources(Request request,
Predicate predicate)
Update the resources selected by the given predicate with the properties
from the given request object.
|
RequestStatus |
ThemeArtifactResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
PermissionResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
WorkflowResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
UpgradeSummaryResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
ArtifactResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
RequestScheduleResourceProvider.updateResources(Request request,
Predicate predicate)
Currently unsupported operation.
|
RequestStatus |
HostComponentResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
FeedResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
LdapSyncEventResourceProvider.updateResources(Request event,
Predicate predicate) |
RequestStatus |
UpgradeItemResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
TaskResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
AlertGroupResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
UpgradeGroupResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
ExtensionResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
WidgetResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
RepositoryResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
RequestResourceProvider.updateResources(Request requestInfo,
Predicate predicate) |
RequestStatus |
WidgetLayoutResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
ActionResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
TaskAttemptResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
ViewVersionResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
BlueprintResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
ConfigurationResourceProvider.updateResources(Request request,
Predicate predicate)
Throws an exception, as Configurations cannot be updated.
|
RequestStatus |
ReadOnlyResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
ClientConfigResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
UserResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
UserAuthenticationSourceResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
TargetClusterResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
AlertHistoryResourceProvider.updateResources(Request request,
Predicate predicate)
Update the resources selected by the given predicate with the properties
from the given request object.
|
RequestStatus |
AlertNoticeResourceProvider.updateResources(Request request,
Predicate predicate)
Update the resources selected by the given predicate with the properties
from the given request object.
|
RequestStatus |
StackDependencyResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
KerberosDescriptorResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
JobResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
StackArtifactResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
UpgradeResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
ViewPermissionResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
StageResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
ClusterControllerImpl.updateResources(Resource.Type type,
Request request,
Predicate predicate) |
RequestStatus |
ConfigGroupResourceProvider.updateResources(Set<ConfigGroupRequest> requests) |
protected RequestStatus |
ViewResourceProvider.updateResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
ViewInstanceResourceProvider.updateResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
AlertTargetResourceProvider.updateResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
HostResourceProvider.updateResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
RepositoryVersionResourceProvider.updateResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
RootServiceComponentConfigurationResourceProvider.updateResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
CredentialResourceProvider.updateResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
GroupResourceProvider.updateResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
ViewURLResourceProvider.updateResourcesAuthorized(Request request,
Predicate predicate) |
RequestStatus |
RemoteClusterResourceProvider.updateResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
VersionDefinitionResourceProvider.updateResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
AbstractAuthorizedResourceProvider.updateResourcesAuthorized(Request request,
Predicate predicate)
Update the resources selected by the given predicate with the properties from the given request
object if the authenticated user is authorized to do so.
|
RequestStatus |
SettingResourceProvider.updateResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
ClusterResourceProvider.updateResourcesAuthorized(Request request,
Predicate predicate) |
RequestStatus |
ComponentResourceProvider.updateResourcesAuthorized(Request request,
Predicate predicate) |
RequestStatus |
PrivilegeResourceProvider.updateResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
MemberResourceProvider.updateResourcesAuthorized(Request request,
Predicate predicate) |
protected RequestStatus |
ServiceResourceProvider.updateResourcesAuthorized(Request request,
Predicate predicate) |
RequestStatus |
ConfigGroupResourceProvider.updateResourcesAuthorized(Request request,
Predicate predicate) |
Modifier and Type | Method and Description |
---|---|
RequestStatus |
JDBCResourceProvider.createResources(Request request) |
RequestStatus |
JDBCResourceProvider.deleteResources(Request request,
Predicate predicate) |
Set<Resource> |
JDBCResourceProvider.getResources(Request request,
Predicate predicate) |
RequestStatus |
JDBCResourceProvider.updateResources(Request request,
Predicate predicate) |
Modifier and Type | Method and Description |
---|---|
protected Resource |
JMXPropertyProvider.populateResource(Resource resource,
Request request,
Predicate predicate,
ThreadPoolEnabledPropertyProvider.Ticket ticket)
Populate a resource by obtaining the requested JMX properties.
|
Set<Resource> |
JMXPropertyProvider.populateResources(Set<Resource> resources,
Request request,
Predicate predicate) |
Modifier and Type | Method and Description |
---|---|
Set<Resource> |
LoggingSearchPropertyProvider.populateResources(Set<Resource> resources,
Request request,
Predicate predicate) |
Modifier and Type | Method and Description |
---|---|
String |
MetricHostProvider.getCollectorHostName(String clusterName,
MetricsServiceProvider.MetricsService service)
Get the metrics server host name for the given cluster name.
|
String |
MetricHostProvider.getCollectorPort(String clusterName,
MetricsServiceProvider.MetricsService service)
Get the metrics server port for the given cluster name.
|
String |
ThreadPoolEnabledPropertyProvider.getHost(Resource resource,
String clusterName,
String componentName)
Returns a hostname for component
|
String |
MetricHostProvider.getHostName(String clusterName,
String componentName)
Get the host name for the given cluster name and component name.
|
boolean |
MetricHostProvider.isCollectorComponentLive(String clusterName,
MetricsServiceProvider.MetricsService service)
Get the status of metrics server component for the given cluster name.
|
boolean |
MetricHostProvider.isCollectorHostLive(String clusterName,
MetricsServiceProvider.MetricsService service)
Get the status of metrics server host for the given cluster name.
|
protected Resource |
RestMetricsPropertyProvider.populateResource(Resource resource,
Request request,
Predicate predicate,
ThreadPoolEnabledPropertyProvider.Ticket ticket)
Populate a resource by obtaining the requested REST properties.
|
protected abstract Resource |
ThreadPoolEnabledPropertyProvider.populateResource(Resource resource,
Request request,
Predicate predicate,
ThreadPoolEnabledPropertyProvider.Ticket ticket)
Populate a resource by obtaining the requested JMX properties.
|
Set<Resource> |
MetricsReportPropertyProviderProxy.populateResources(Set<Resource> resources,
Request request,
Predicate predicate) |
Set<Resource> |
MetricsPropertyProvider.populateResources(Set<Resource> resources,
Request request,
Predicate predicate) |
Set<Resource> |
ThreadPoolEnabledPropertyProvider.populateResources(Set<Resource> resources,
Request request,
Predicate predicate) |
Set<Resource> |
MetricsPropertyProviderProxy.populateResources(Set<Resource> resources,
Request request,
Predicate predicate) |
protected abstract Set<Resource> |
MetricsPropertyProvider.populateResourcesWithProperties(Set<Resource> resources,
Request request,
Set<String> propertyIds)
Delegate implementation of populating resources to concrete providers.
|
protected static void |
ThreadPoolEnabledPropertyProvider.rethrowSystemException(Throwable throwable)
Rethrow the given exception as a System exception and log the message.
|
Modifier and Type | Method and Description |
---|---|
protected String |
GangliaReportPropertyProvider.getSpec(String clusterName,
String report)
Get the spec to locate the Ganglia stream from the given
request info.
|
Set<Resource> |
GangliaReportPropertyProvider.populateResources(Set<Resource> resources,
Request request,
Predicate predicate) |
Set<Resource> |
GangliaPropertyProvider.populateResourcesWithProperties(Set<Resource> resources,
Request request,
Set<String> propertyIds) |
Modifier and Type | Method and Description |
---|---|
Set<Resource> |
AMSReportPropertyProvider.populateResources(Set<Resource> resources,
Request request,
Predicate predicate) |
Set<Resource> |
AMSPropertyProvider.populateResourcesWithProperties(Set<Resource> resources,
Request request,
Set<String> propertyIds) |
Modifier and Type | Method and Description |
---|---|
RequestStatus |
ResourceProvider.createResources(Request request)
Create the resources defined by the properties in the given request object.
|
RequestStatus |
ClusterController.createResources(Resource.Type type,
Request request)
Create the resources defined by the properties in the given request object.
|
RequestStatus |
ResourceProvider.deleteResources(Request request,
Predicate predicate)
Delete the resources selected by the given predicate.
|
RequestStatus |
ClusterController.deleteResources(Resource.Type type,
Request request,
Predicate predicate)
Delete the resources selected by the given predicate.
|
Iterable<Resource> |
ClusterController.getIterable(Resource.Type type,
QueryResponse queryResponse,
Request request,
Predicate predicate,
PageRequest pageRequest,
SortRequest sortRequest)
Get an iterable set of resources from the given set of resources filtered by the
given request and predicate objects.
|
PageResponse |
ClusterController.getPage(Resource.Type type,
QueryResponse queryResponse,
Request request,
Predicate predicate,
PageRequest pageRequest,
SortRequest sortRequest)
Get a page of resources from the given set filtered by the given request,
predicate objects and page request.
|
Set<Resource> |
ResourceProvider.getResources(Request request,
Predicate predicate)
Get a set of
resources based on the given request and predicate
information. |
QueryResponse |
ClusterController.getResources(Resource.Type type,
Request request,
Predicate predicate)
Get the resources of the given type filtered by the given request and
predicate objects.
|
Set<Resource> |
ClusterController.populateResources(Resource.Type type,
Set<Resource> resources,
Request request,
Predicate predicate)
Populate the given resources from the associated property providers.
|
Set<Resource> |
PropertyProvider.populateResources(Set<Resource> resources,
Request request,
Predicate predicate)
Populate the given set of resource with any properties that this property
provider can provide and return a populated set of resources.
|
QueryResponse |
ExtendedResourceProvider.queryForResources(Request request,
Predicate predicate)
Query for resources that match the given predicate.
|
RequestStatus |
ResourceProvider.updateResources(Request request,
Predicate predicate)
Update the resources selected by the given predicate with the properties
from the given request object.
|
RequestStatus |
ClusterController.updateResources(Resource.Type type,
Request request,
Predicate predicate)
Update the resources selected by the given predicate with the properties
from the given request object.
|
Modifier and Type | Class and Description |
---|---|
class |
AuthorizationException
AuthorizationException indicates that the authenticated user is not authorized to perform some
operation.
|
Modifier and Type | Method and Description |
---|---|
void |
RepositoryVersionHelper.addCommandRepositoryToContext(ActionExecutionContext context,
RepositoryVersionEntity repoVersion,
RepoOsEntity osEntity)
Adds a command repository to the action context
|
Map<String,String> |
RepositoryVersionHelper.buildRoleParams(AmbariManagementController amc,
RepositoryVersionEntity repoVersion,
String osFamily,
Set<String> servicesOnHost)
Build the role parameters for an install command.
|
CommandRepository |
RepositoryVersionHelper.getCommandRepository(Cluster cluster,
ServiceComponent component,
Host host)
Builds repository information for inclusion in a command.
|
CommandRepository |
RepositoryVersionHelper.getCommandRepository(RepositoryVersionEntity repoVersion,
RepoOsEntity osEntity)
Adds a command repository to the action context
|
RepoOsEntity |
RepositoryVersionHelper.getOSEntityForHost(Host host,
RepositoryVersionEntity repoVersion)
Return repositories available for target os version on host based on
repoVersion repository definition |
String |
RepositoryVersionHelper.getRepoInfo(Cluster cluster,
ServiceComponent component,
Host host)
Deprecated.
|
String |
RepositoryVersionHelper.getRepoInfoString(Cluster cluster,
ServiceComponent component,
Host host)
Get repository info given a cluster and host.
|
Modifier and Type | Method and Description |
---|---|
Resource |
UpgradeHelper.getTaskResource(String clusterName,
Long requestId,
Long stageId,
Long taskId)
Get a single resource for the task with the given parameters.
|
Modifier and Type | Method and Description |
---|---|
RequestStatus |
ViewExternalSubResourceProvider.createResources(Request request) |
RequestStatus |
ViewSubResourceProvider.createResources(Request request) |
RequestStatus |
ViewExternalSubResourceProvider.deleteResources(Request request,
Predicate predicate) |
RequestStatus |
ViewSubResourceProvider.deleteResources(Request request,
Predicate predicate) |
Set<Resource> |
ViewExternalSubResourceProvider.getResources(Request request,
Predicate predicate) |
Set<Resource> |
ViewSubResourceProvider.getResources(Request request,
Predicate predicate) |
RequestStatus |
ViewExternalSubResourceProvider.updateResources(Request request,
Predicate predicate) |
RequestStatus |
ViewSubResourceProvider.updateResources(Request request,
Predicate predicate) |
Copyright © 2022 Apache Software Foundation. All rights reserved.