Modifier and Type | Method and Description |
---|---|
void |
Stage.addHostRoleExecutionCommand(Host host,
Role role,
RoleCommand command,
ServiceComponentHostEvent event,
Cluster cluster,
String serviceName,
boolean retryAllowed,
boolean autoSkipFailure)
A new host role command is created for execution.
|
void |
ExecutionCommandWrapper.setVersions(Cluster cluster,
CommandRepository commandRepository) |
Modifier and Type | Method and Description |
---|---|
void |
AlertDefinitionCommand.addConfigs(ConfigHelper configHelper,
Cluster cluster)
Adds cluster configuration properties as required by commands sent to agent.
|
void |
ExecutionCommand.setComponentVersions(Cluster cluster)
Used to set a map of {service -> { component -> version}}.
|
Modifier and Type | Method and Description |
---|---|
protected Alert |
AlertRunnable.buildAlert(Cluster cluster,
AlertDefinitionEntity myDefinition,
AlertState alertState,
String message)
Builds an
Alert instance. |
Modifier and Type | Method and Description |
---|---|
void |
AmbariMetaInfo.reconcileAlertDefinitions(Cluster cluster,
boolean updateScriptPaths)
Compares the alert definitions defined on the stack with those in the
database and merges any new or updated definitions.
|
Modifier and Type | Method and Description |
---|---|
RequestStageContainer |
AmbariManagementController.addStages(RequestStageContainer requestStages,
Cluster cluster,
Map<String,String> requestProperties,
Map<String,String> requestParameters,
Map<State,List<Service>> changedServices,
Map<State,List<ServiceComponent>> changedComponents,
Map<String,Map<State,List<ServiceComponentHost>>> changedHosts,
Collection<ServiceComponentHost> ignoredHosts,
boolean runSmokeTest,
boolean reconfigureClients,
boolean useGeneratedConfigs)
Add stages to the request.
|
RequestStageContainer |
AmbariManagementControllerImpl.addStages(RequestStageContainer requestStages,
Cluster cluster,
Map<String,String> requestProperties,
Map<String,String> requestParameters,
Map<State,List<Service>> changedServices,
Map<State,List<ServiceComponent>> changedComponents,
Map<String,Map<State,List<ServiceComponentHost>>> changedHosts,
Collection<ServiceComponentHost> ignoredHosts,
boolean runSmokeTest,
boolean reconfigureClients,
boolean useGeneratedConfigs) |
RequestStageContainer |
AmbariManagementController.addStages(RequestStageContainer requestStages,
Cluster cluster,
Map<String,String> requestProperties,
Map<String,String> requestParameters,
Map<State,List<Service>> changedServices,
Map<State,List<ServiceComponent>> changedComponents,
Map<String,Map<State,List<ServiceComponentHost>>> changedHosts,
Collection<ServiceComponentHost> ignoredHosts,
boolean runSmokeTest,
boolean reconfigureClients,
boolean useGeneratedConfigs,
boolean useClusterHostInfo)
Add stages to the request.
|
RequestStageContainer |
AmbariManagementControllerImpl.addStages(RequestStageContainer requestStages,
Cluster cluster,
Map<String,String> requestProperties,
Map<String,String> requestParameters,
Map<State,List<Service>> changedServices,
Map<State,List<ServiceComponent>> changedComponents,
Map<String,Map<State,List<ServiceComponentHost>>> changedHosts,
Collection<ServiceComponentHost> ignoredHosts,
boolean runSmokeTest,
boolean reconfigureClients,
boolean useGeneratedConfigs,
boolean useClusterHostInfo) |
Map<String,Map<String,String>> |
KerberosHelperImpl.applyStackAdvisorUpdates(Cluster cluster,
Set<String> services,
Map<String,Map<String,String>> existingConfigurations,
Map<String,Map<String,String>> kerberosConfigurations,
Map<String,Set<String>> propertiesToIgnore,
Map<String,Set<String>> propertiesToRemove,
boolean kerberosEnabled) |
Map<String,Map<String,String>> |
KerberosHelper.applyStackAdvisorUpdates(Cluster cluster,
Set<String> services,
Map<String,Map<String,String>> existingConfigurations,
Map<String,Map<String,String>> kerberosConfigurations,
Map<String,Set<String>> propertiesToIgnore,
Map<String,Set<String>> propertiesToRemove,
boolean kerberosEnabled)
Invokes the Stack Advisor to help determine relevant configuration changes when enabling or
disabling Kerberos.
|
Map<String,Map<String,String>> |
KerberosHelperImpl.calculateConfigurations(Cluster cluster,
String hostname,
KerberosDescriptor kerberosDescriptor,
boolean includePreconfigureData,
boolean calculateClusterHostInfo) |
Map<String,Map<String,String>> |
KerberosHelper.calculateConfigurations(Cluster cluster,
String hostname,
KerberosDescriptor kerberosDescriptor,
boolean includePreconfigureData,
boolean calculateClusterHostInfo)
Calculates the map of configurations relative to the cluster and host.
|
void |
KerberosHelperImpl.configureServices(Cluster cluster,
Map<String,Collection<String>> serviceFilter) |
void |
KerberosHelper.configureServices(Cluster cluster,
Map<String,Collection<String>> serviceFilter)
Updates the relevant configurations for the components specified in the service filter.
|
RequestStatusResponse |
AmbariManagementController.createAndPersistStages(Cluster cluster,
Map<String,String> requestProperties,
Map<String,String> requestParameters,
Map<State,List<Service>> changedServices,
Map<State,List<ServiceComponent>> changedComponents,
Map<String,Map<State,List<ServiceComponentHost>>> changedHosts,
Collection<ServiceComponentHost> ignoredHosts,
boolean runSmokeTest,
boolean reconfigureClients)
Create and persist the request stages and return a response containing the
associated request and resulting tasks.
|
RequestStatusResponse |
AmbariManagementControllerImpl.createAndPersistStages(Cluster cluster,
Map<String,String> requestProperties,
Map<String,String> requestParameters,
Map<State,List<Service>> changedServices,
Map<State,List<ServiceComponent>> changedComponents,
Map<String,Map<State,List<ServiceComponentHost>>> changedHosts,
Collection<ServiceComponentHost> ignoredHosts,
boolean runSmokeTest,
boolean reconfigureClients) |
Config |
AmbariManagementController.createConfig(Cluster cluster,
StackId stackId,
String type,
Map<String,String> properties,
String versionTag,
Map<String,Map<String,String>> propertiesAttributes)
Create cluster config
TODO move this method to Cluster? doesn't seem to be on its place
|
Config |
AmbariManagementControllerImpl.createConfig(Cluster cluster,
StackId stackId,
String type,
Map<String,String> properties,
String versionTag,
Map<String,Map<String,String>> propertiesAttributes) |
RequestStageContainer |
KerberosHelperImpl.createTestIdentity(Cluster cluster,
Map<String,String> commandParamsStage,
RequestStageContainer requestStageContainer) |
RequestStageContainer |
KerberosHelper.createTestIdentity(Cluster cluster,
Map<String,String> commandParamsStage,
RequestStageContainer requestStageContainer)
Create a unique identity to use for testing the general Kerberos configuration.
|
void |
KerberosHelperImpl.deleteIdentities(Cluster cluster,
List<Component> components,
Set<String> identities)
Deletes the kerberos identities of the given component, even if the component is already deleted.
|
void |
KerberosHelper.deleteIdentities(Cluster cluster,
List<Component> components,
Set<String> identities) |
RequestStageContainer |
KerberosHelperImpl.deleteIdentities(Cluster cluster,
Map<String,? extends Collection<String>> serviceComponentFilter,
Set<String> hostFilter,
Collection<String> identityFilter,
RequestStageContainer requestStageContainer,
Boolean manageIdentities) |
RequestStageContainer |
KerberosHelper.deleteIdentities(Cluster cluster,
Map<String,? extends Collection<String>> serviceComponentFilter,
Set<String> hostFilter,
Collection<String> identityFilter,
RequestStageContainer requestStageContainer,
Boolean manageIdentities)
Deletes the set of filtered principals and keytabs from the cluster.
|
RequestStageContainer |
KerberosHelperImpl.deleteTestIdentity(Cluster cluster,
Map<String,String> commandParamsStage,
RequestStageContainer requestStageContainer) |
RequestStageContainer |
KerberosHelper.deleteTestIdentity(Cluster cluster,
Map<String,String> commandParamsStage,
RequestStageContainer requestStageContainer)
Deletes the unique identity to use for testing the general Kerberos configuration.
|
protected RequestStageContainer |
AmbariManagementControllerImpl.doStageCreation(RequestStageContainer requestStages,
Cluster cluster,
Map<State,List<Service>> changedServices,
Map<State,List<ServiceComponent>> changedComps,
Map<String,Map<State,List<ServiceComponentHost>>> changedScHosts,
Map<String,String> requestParameters,
Map<String,String> requestProperties,
boolean runSmokeTest,
boolean reconfigureClients,
boolean useLatestConfigs,
boolean useClusterHostInfo) |
boolean |
KerberosHelperImpl.ensureHeadlessIdentities(Cluster cluster,
Map<String,Map<String,String>> existingConfigurations,
Set<String> services) |
boolean |
KerberosHelper.ensureHeadlessIdentities(Cluster cluster,
Map<String,Map<String,String>> existingConfigurations,
Set<String> services)
Ensures that the relevant headless (or user) Kerberos identities are created and cached.
|
RequestStageContainer |
KerberosHelperImpl.ensureIdentities(Cluster cluster,
Map<String,? extends Collection<String>> serviceComponentFilter,
Set<String> hostFilter,
Collection<String> identityFilter,
Set<String> hostsToForceKerberosOperations,
RequestStageContainer requestStageContainer,
Boolean manageIdentities) |
RequestStageContainer |
KerberosHelper.ensureIdentities(Cluster cluster,
Map<String,? extends Collection<String>> serviceComponentFilter,
Set<String> hostFilter,
Collection<String> identityFilter,
Set<String> hostsToForceKerberosOperations,
RequestStageContainer requestStageContainer,
Boolean manageIdentities)
Ensures the set of filtered principals and keytabs exist on the cluster.
|
RequestStageContainer |
KerberosHelperImpl.executeCustomOperations(Cluster cluster,
Map<String,String> requestProperties,
RequestStageContainer requestStageContainer,
Boolean manageIdentities) |
RequestStageContainer |
KerberosHelper.executeCustomOperations(Cluster cluster,
Map<String,String> requestProperties,
RequestStageContainer requestStageContainer,
Boolean manageIdentities)
Used to execute custom security operations which are sent as directives in URI
|
protected void |
AmbariManagementControllerImpl.filterHostsForAction(Set<String> candidateHosts,
Service service,
Cluster cluster,
Resource.Type level)
Utility method that filters out hosts from set based on their maintenance
state status.
|
Map<String,Map<String,String>> |
AmbariManagementController.findConfigurationTagsWithOverrides(Cluster cluster,
String hostName)
Find configuration tags with applied overrides
|
Map<String,Map<String,String>> |
AmbariManagementControllerImpl.findConfigurationTagsWithOverrides(Cluster cluster,
String hostName) |
String |
AmbariManagementController.findServiceName(Cluster cluster,
String componentName)
Get service name by cluster instance and component name
|
String |
AmbariManagementControllerImpl.findServiceName(Cluster cluster,
String componentName) |
protected ServiceComponent |
AmbariManagementControllerImpl.getClientComponentForRunningAction(Cluster cluster,
Service service) |
protected String |
AmbariManagementControllerImpl.getClientHostForRunningAction(Cluster cluster,
Service service,
ServiceComponent serviceComponent) |
MetadataUpdateEvent |
AmbariManagementControllerImpl.getClusterMetadata(Cluster cl) |
MetadataUpdateEvent |
AmbariManagementController.getClusterMetadataOnConfigsUpdate(Cluster cluster) |
MetadataUpdateEvent |
AmbariManagementControllerImpl.getClusterMetadataOnConfigsUpdate(Cluster cl) |
MetadataUpdateEvent |
AmbariManagementControllerImpl.getClusterMetadataOnRepoUpdate(Cluster cl) |
MetadataUpdateEvent |
AmbariManagementControllerImpl.getClusterMetadataOnServiceCredentialStoreUpdate(Cluster cl,
String serviceName) |
MetadataUpdateEvent |
AmbariManagementControllerImpl.getClusterMetadataOnServiceInstall(Cluster cl,
String serviceName) |
ExecuteCommandJson |
AmbariCustomCommandExecutionHelper.getCommandJson(ActionExecutionContext actionExecContext,
Cluster cluster,
StackId stackId,
String requestContext)
Helper method to fill execution command information.
|
ExecutionCommand |
AmbariManagementController.getExecutionCommand(Cluster cluster,
ServiceComponentHost scHost,
RoleCommand roleCommand)
Gets an execution command for host component life cycle command
|
ExecutionCommand |
AmbariManagementControllerImpl.getExecutionCommand(Cluster cluster,
ServiceComponentHost scHost,
RoleCommand roleCommand) |
Set<String> |
KerberosHelperImpl.getHostsWithValidKerberosClient(Cluster cluster) |
Set<String> |
KerberosHelper.getHostsWithValidKerberosClient(Cluster cluster) |
String |
AmbariManagementController.getJobTrackerHost(Cluster cluster)
Deprecated.
|
String |
AmbariManagementControllerImpl.getJobTrackerHost(Cluster cluster) |
KerberosDescriptor |
KerberosHelperImpl.getKerberosDescriptor(Cluster cluster,
boolean includePreconfigureData) |
KerberosDescriptor |
KerberosHelper.getKerberosDescriptor(Cluster cluster,
boolean includePreconfigureData)
Builds a composite Kerberos descriptor using the default Kerberos descriptor and a user-specified
Kerberos descriptor, if it exists.
|
KerberosDescriptor |
KerberosHelperImpl.getKerberosDescriptor(KerberosHelper.KerberosDescriptorType kerberosDescriptorType,
Cluster cluster,
boolean evaluateWhenClauses,
Collection<String> additionalServices,
boolean includePreconfigureData) |
KerberosDescriptor |
KerberosHelper.getKerberosDescriptor(KerberosHelper.KerberosDescriptorType kerberosDescriptorType,
Cluster cluster,
boolean evaluateWhenClauses,
Collection<String> additionalServices,
boolean includePreconfigureData)
Gets the requested Kerberos descriptor.
|
KerberosDescriptor |
KerberosHelperImpl.getKerberosDescriptor(KerberosHelper.KerberosDescriptorType kerberosDescriptorType,
Cluster cluster,
StackId stackId,
boolean includePreconfigureData) |
KerberosDescriptor |
KerberosHelper.getKerberosDescriptor(KerberosHelper.KerberosDescriptorType kerberosDescriptorType,
Cluster cluster,
StackId stackId,
boolean includePreconfigureData)
Gets the Kerberos descriptor for the requested stack.
|
KerberosDetails |
KerberosHelperImpl.getKerberosDetails(Cluster cluster,
Boolean manageIdentities)
Gathers the Kerberos-related data from configurations and stores it in a new KerberosDetails
instance.
|
KerberosDetails |
KerberosHelper.getKerberosDetails(Cluster cluster,
Boolean manageIdentities)
Gathers the Kerberos-related data from configurations and stores it in a new KerberosDetails
instance.
|
Set<Map<String,String>> |
MaintenanceStateHelper.getMaintenanceHostComponents(Clusters clusters,
Cluster cluster) |
TreeMap<String,String> |
AmbariManagementControllerImpl.getMetadataClusterLevelParams(Cluster cluster,
StackId stackId) |
TreeMap<String,MetadataServiceInfo> |
AmbariManagementControllerImpl.getMetadataServiceLevelParams(Cluster cluster) |
RoleCommandOrder |
AmbariManagementController.getRoleCommandOrder(Cluster cluster)
Get Role Command Order
|
RoleCommandOrder |
AmbariManagementControllerImpl.getRoleCommandOrder(Cluster cluster) |
List<ServiceComponentHost> |
KerberosHelperImpl.getServiceComponentHostsToProcess(Cluster cluster,
KerberosDescriptor kerberosDescriptor,
Map<String,? extends Collection<String>> serviceComponentFilter,
Collection<String> hostFilter) |
List<ServiceComponentHost> |
KerberosHelper.getServiceComponentHostsToProcess(Cluster cluster,
KerberosDescriptor kerberosDescriptor,
Map<String,? extends Collection<String>> serviceComponentFilter,
Collection<String> hostFilter) |
Map<String,Map<String,String>> |
KerberosHelperImpl.getServiceConfigurationUpdates(Cluster cluster,
Map<String,Map<String,String>> existingConfigurations,
Map<String,Set<String>> installedServices,
Map<String,Collection<String>> serviceFilter,
Set<String> previouslyExistingServices,
boolean kerberosEnabled,
boolean applyStackAdvisorUpdates) |
Map<String,Map<String,String>> |
KerberosHelper.getServiceConfigurationUpdates(Cluster cluster,
Map<String,Map<String,String>> existingConfigurations,
Map<String,Set<String>> installedServices,
Map<String,Collection<String>> serviceFilter,
Set<String> previouslyExistingServices,
boolean kerberosEnabled,
boolean applyStackAdvisorUpdates)
Returns the updates configurations that are expected when the given set of services are configured
for Kerberos.
|
void |
AmbariManagementController.initializeWidgetsAndLayouts(Cluster cluster,
Service service)
Initialize cluster scoped widgets and widgetLayouts for different stack
components.
|
void |
AmbariManagementControllerImpl.initializeWidgetsAndLayouts(Cluster cluster,
Service service) |
boolean |
KerberosHelperImpl.isClusterKerberosEnabled(Cluster cluster) |
boolean |
KerberosHelper.isClusterKerberosEnabled(Cluster cluster)
Determine if a cluster has kerberos enabled.
|
boolean |
MaintenanceStateHelper.isOperationAllowed(Cluster cluster,
RequestOperationLevel levelObj,
RequestResourceFilter reqFilter,
String serviceName,
String componentName,
String hostname) |
Map<String,Map<String,String>> |
KerberosHelperImpl.processPreconfiguredServiceConfigurations(Map<String,Map<String,String>> configurations,
Map<String,Map<String,String>> replacements,
Cluster cluster,
KerberosDescriptor kerberosDescriptor) |
Map<String,Map<String,String>> |
KerberosHelper.processPreconfiguredServiceConfigurations(Map<String,Map<String,String>> configurations,
Map<String,Map<String,String>> replacements,
Cluster cluster,
KerberosDescriptor kerberosDescriptor)
Determines which services, not currently installed, should be preconfigured to aid in reducing
the number of service restarts when new services are added to a cluster where Kerberos is enabled.
|
void |
KerberosHelperImpl.setAuthToLocalRules(Cluster cluster,
KerberosDescriptor kerberosDescriptor,
String realm,
Map<String,Set<String>> installedServices,
Map<String,Map<String,String>> existingConfigurations,
Map<String,Map<String,String>> kerberosConfigurations,
boolean includePreconfigureData) |
void |
KerberosHelper.setAuthToLocalRules(Cluster cluster,
KerberosDescriptor kerberosDescriptor,
String realm,
Map<String,Set<String>> installedServices,
Map<String,Map<String,String>> existingConfigurations,
Map<String,Map<String,String>> kerberosConfigurations,
boolean includePreconfigureData)
Sets the relevant auth-to-local rule configuration properties using the services installed on
the cluster and their relevant Kerberos descriptors to determine the rules to be created.
|
RequestStageContainer |
KerberosHelperImpl.toggleKerberos(Cluster cluster,
SecurityType securityType,
RequestStageContainer requestStageContainer,
Boolean manageIdentities) |
RequestStageContainer |
KerberosHelper.toggleKerberos(Cluster cluster,
SecurityType securityType,
RequestStageContainer requestStageContainer,
Boolean manageIdentities)
Toggles Kerberos security to enable it or remove it depending on the state of the cluster.
|
protected void |
AmbariManagementControllerImpl.validateAuthorizationToManageServiceAutoStartConfiguration(Cluster cluster,
String configType,
Map<String,String[]> propertyChanges)
Validates that the authenticated user can manage the cluster-wide configuration for a service's
ability to be set to auto-start.
|
protected void |
AmbariManagementControllerImpl.validateAuthorizationToUpdateServiceUsersAndGroups(Cluster cluster,
String configType,
Map<String,String[]> propertyChanges)
Validates that the authenticated user can set a service's (run-as) user and group.
|
void |
KerberosHelperImpl.validateKDCCredentials(Cluster cluster) |
void |
KerberosHelper.validateKDCCredentials(Cluster cluster)
Validate the KDC admin credentials.
|
Modifier and Type | Method and Description |
---|---|
protected Set<RecommendationResponse.ConfigGroup> |
StackAdvisorResourceProvider.calculateConfigGroups(Cluster cluster,
Request request) |
protected Map<String,Map<String,Map<String,String>>> |
StackAdvisorResourceProvider.calculateConfigurations(Cluster cluster,
String serviceName) |
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) |
Constructor and Description |
---|
LoggingRequestHelperImpl(String hostName,
String portNumber,
String protocol,
CredentialStoreService credentialStoreService,
Cluster cluster,
String externalAddress) |
LoggingRequestHelperImpl(String hostName,
String portNumber,
String protocol,
CredentialStoreService credentialStoreService,
Cluster cluster,
String externalAddress,
org.apache.ambari.server.controller.logging.LoggingRequestHelperImpl.NetworkConnection networkConnection) |
Modifier and Type | Method and Description |
---|---|
protected String |
RestMetricsPropertyProvider.resolvePort(Cluster cluster,
String hostname,
String componentName,
Map<String,String> metricsProperties,
String protocol)
If protocol is equal to HTTPS_PROTOCOL than returns HTTPS_PORT_PROPERTY_NAME_PROPERTY value from PORT_CONFIG_TYPE_PROPERTY
else uses port_config_type, port_property_name, default_port parameters from
metricsProperties to find out right port value for service
|
Modifier and Type | Method and Description |
---|---|
static RemovableIdentities |
RemovableIdentities.ofComponent(Cluster cluster,
ServiceComponentUninstalledEvent event,
KerberosHelper kerberosHelper)
Populate the identities with the identities of the removed component
|
static RemovableIdentities |
RemovableIdentities.ofService(Cluster cluster,
ServiceRemovedEvent event,
KerberosHelper kerberosHelper)
Populate the identities with the identities of the removed service and its components
|
static UsedIdentities |
UsedIdentities.populate(Cluster cluster,
UsedIdentities.ServiceExclude serviceExclude,
UsedIdentities.ComponentExclude componentExclude,
KerberosHelper kerberosHelper)
Get all identities of the installed services and components.
|
Modifier and Type | Method and Description |
---|---|
protected Cluster |
DefaultServiceCalculatedState.getCluster(String clusterName) |
Modifier and Type | Field and Description |
---|---|
protected Cluster |
StackUpgradeFinishEvent.cluster |
protected Cluster |
HostComponentVersionAdvertisedEvent.cluster |
Modifier and Type | Method and Description |
---|---|
Cluster |
StackUpgradeFinishEvent.getCluster() |
Cluster |
HostComponentVersionAdvertisedEvent.getCluster() |
Constructor and Description |
---|
ConfigsUpdateEvent(Cluster cluster,
Collection<ClusterConfigEntity> configs) |
HostComponentVersionAdvertisedEvent(Cluster cluster,
ServiceComponentHost sch,
String version)
Constructor.
|
HostComponentVersionAdvertisedEvent(Cluster cluster,
ServiceComponentHost sch,
String version,
Long repoVersionId)
Constructor.
|
StackUpgradeFinishEvent(Cluster cluster)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
RoleCommandOrder |
CachedRoleCommandOrderProvider.getRoleCommandOrder(Cluster cluster) |
RoleCommandOrder |
RoleCommandOrderProvider.getRoleCommandOrder(Cluster cluster) |
void |
RoleCommandOrder.initialize(Cluster cluster,
LinkedHashSet<String> sectionKeys) |
Modifier and Type | Method and Description |
---|---|
protected void |
PropertiesEncryptor.encrypt(Map<String,String> configProperties,
Cluster cluster,
String configType) |
protected void |
PropertiesEncryptor.encrypt(Map<String,String> configProperties,
Cluster cluster,
String configType,
Function<String,String> encryption) |
protected void |
PropertiesEncryptor.encrypt(Map<String,String> configProperties,
Cluster cluster,
String configType,
String encryptionKey) |
Modifier and Type | Method and Description |
---|---|
protected Cluster |
KerberosServerAction.getCluster()
Returns the relevant Cluster object
|
Modifier and Type | Method and Description |
---|---|
protected KerberosDescriptor |
PrepareKerberosIdentitiesServerAction.getKerberosDescriptor(Cluster cluster,
boolean includePreconfigureData)
|
void |
AbstractPrepareKerberosServerAction.processServiceComponentHosts(Cluster cluster,
KerberosDescriptor kerberosDescriptor,
List<ServiceComponentHost> schToProcess,
Collection<String> identityFilter,
String dataDirectory,
Map<String,Map<String,String>> currentConfigurations,
Map<String,Map<String,String>> kerberosConfigurations,
boolean includeAmbariIdentity,
Map<String,Set<String>> propertiesToBeIgnored) |
protected void |
AbstractPrepareKerberosServerAction.processServiceComponents(Cluster cluster,
KerberosDescriptor kerberosDescriptor,
List<Component> schToProcess,
Collection<String> identityFilter,
String dataDirectory,
Map<String,Map<String,String>> currentConfigurations,
Map<String,Map<String,String>> kerberosConfigurations,
boolean includeAmbariIdentity,
Map<String,Set<String>> propertiesToBeIgnored) |
Modifier and Type | Method and Description |
---|---|
Map<String,Collection<String>> |
KerberosKeytabController.adjustServiceComponentFilter(Cluster cluster,
boolean includeAmbariAsService,
Map<String,? extends Collection<String>> serviceComponentFilter)
Adjust service component filter according to installed services
|
Modifier and Type | Method and Description |
---|---|
protected UpgradeContext |
AbstractUpgradeServerAction.getUpgradeContext(Cluster cluster)
Gets an initialized
UpgradeContext for the in-progress upgrade. |
Modifier and Type | Method and Description |
---|---|
Cluster |
MasterHostResolver.getCluster()
Gets the cluster that this instance of the
MasterHostResolver is
initialized with. |
Modifier and Type | Method and Description |
---|---|
static List<NameService> |
NameService.fromConfig(ConfigHelper config,
Cluster cluster) |
static NameService.NameNode |
NameService.NameNode.fromConfig(String nameServiceId,
String nnUniqueId,
ConfigHelper config,
Cluster cluster) |
static Collection<Host> |
MasterHostResolver.getCandidateHosts(Cluster cluster,
ExecuteHostType executeHostType,
String serviceName,
String componentName)
Gets hosts which match the supplied criteria.
|
static HostsType |
HostsType.healthy(Cluster cluster)
Create an instance with all healthy hosts.
|
Constructor and Description |
---|
MasterHostResolver(Cluster cluster,
ConfigHelper configHelper,
UpgradeContext upgradeContext)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
RepositoryVersionHelper.addRepoInfoToHostLevelParams(Cluster cluster,
ActionExecutionContext actionContext,
RepositoryVersionEntity repositoryVersion,
Map<String,String> hostLevelParams,
String hostName)
Deprecated.
|
CommandRepository |
RepositoryVersionHelper.getCommandRepository(Cluster cluster,
ServiceComponent component,
Host host)
Builds repository information for inclusion in a command.
|
CommandRepository |
RepositoryVersionHelper.getCommandRepository(Cluster cluster,
Service service,
Host host,
String componentName) |
Map<String,String> |
ConfigureTask.getConfigurationChanges(Cluster cluster,
ConfigUpgradePack configUpgradePack)
Gets a map containing the following properties pertaining to the
configuration value to change:
ConfigureTask.PARAMETER_CONFIG_TYPE - the configuration type (ie hdfs-site)
ConfigureTask.PARAMETER_KEY_VALUE_PAIRS - key/value pairs for the
configurations
ConfigureTask.PARAMETER_KEY_VALUE_PAIRS - key/value pairs for the
configurations
ConfigureTask.PARAMETER_TRANSFERS - COPY/MOVE/DELETE changes
ConfigureTask.PARAMETER_REPLACEMENTS - value replacements
|
List<ConfigUpgradeChangeDefinition.Replace> |
ConfigUpgradeChangeDefinition.getRegexReplacements(Cluster cluster)
Evaluates the
ConfigUpgradeChangeDefinition.RegexReplace instances defined for the upgrade and
converts them into distinct ConfigUpgradeChangeDefinition.Replace objects. |
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 |
---|---|
Cluster |
UpgradeContext.getCluster()
Gets the cluster that the upgrade is for.
|
Modifier and Type | Method and Description |
---|---|
UpgradeContext |
UpgradeContextFactory.create(Cluster cluster,
Map<String,Object> upgradeRequestMap)
Creates an
UpgradeContext which is injected with dependencies. |
UpgradeContext |
UpgradeContextFactory.create(Cluster cluster,
UpgradeEntity upgradeEntity)
Creates an
UpgradeContext which is injected with dependencies. |
Constructor and Description |
---|
UpgradeContext(Cluster cluster,
Map<String,Object> upgradeRequestMap,
com.google.gson.Gson gson,
UpgradeHelper upgradeHelper,
UpgradeDAO upgradeDAO,
RepositoryVersionDAO repoVersionDAO,
ConfigHelper configHelper,
AmbariMetaInfo metaInfo) |
UpgradeContext(Cluster cluster,
UpgradeEntity upgradeEntity,
AmbariMetaInfo ambariMetaInfo,
ConfigHelper configHelper)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
Cluster |
Service.getCluster() |
Cluster |
Config.getCluster() |
Cluster |
ServiceImpl.getCluster() |
Cluster |
ConfigImpl.getCluster() |
Cluster |
Clusters.getCluster(Long clusterId)
Gets the Cluster given the cluster id
|
Cluster |
Clusters.getCluster(String clusterName)
Gets the Cluster given the cluster name
|
Cluster |
Clusters.getClusterById(long id)
Gets the cluster using the id.
|
Modifier and Type | Method and Description |
---|---|
Map<String,Cluster> |
Clusters.getClusters()
Get all clusters
|
Set<Cluster> |
Clusters.getClustersForHost(String hostname)
Returns all the cluster names for this hostname
|
Modifier and Type | Method and Description |
---|---|
Collection<String> |
ServiceComponentSupport.allUnsupported(Cluster cluster,
String stackName,
String stackVersion) |
org.apache.commons.lang3.tuple.Pair<Map<String,Map<String,String>>,Map<String,Map<String,Map<String,String>>>> |
ConfigHelper.calculateExistingConfigs(Cluster cluster)
Determines the existing configurations for the cluster, both properties and attributes.
|
Map<String,Map<String,String>> |
ConfigHelper.calculateExistingConfigurations(AmbariManagementController ambariManagementController,
Cluster cluster)
Determines the existing configurations for the cluster
|
Map<String,Map<String,String>> |
ConfigHelper.calculateExistingConfigurations(AmbariManagementController ambariManagementController,
Cluster cluster,
String hostname)
Determines the existing configurations for the cluster, related to a given hostname (if provided)
|
void |
ConfigHelper.checkAllStageConfigsPresentInDesiredConfigs(Cluster cluster) |
boolean |
ConfigHelper.createConfigType(Cluster cluster,
StackId stackId,
AmbariManagementController controller,
String configType,
Map<String,String> properties,
Map<String,Map<String,String>> propertyAttributes,
String authenticatedUserName,
String serviceVersionNote) |
void |
ConfigHelper.createConfigType(Cluster cluster,
StackId stackId,
AmbariManagementController controller,
String configType,
Map<String,String> properties,
String authenticatedUserName,
String serviceVersionNote) |
boolean |
ConfigHelper.createConfigTypes(Cluster cluster,
StackId stackId,
AmbariManagementController controller,
Map<String,Map<String,String>> batchProperties,
String authenticatedUserName,
String serviceVersionNote)
Create configurations and assign them for services.
|
Config |
ConfigFactory.createExisting(Cluster cluster,
ClusterConfigEntity entity)
Creates a new
Config object using provided entity |
Service |
ServiceFactory.createExisting(Cluster cluster,
ClusterServiceEntity serviceEntity)
Creates an in-memory representation of a service from an existing database
object.
|
Service |
ServiceFactory.createNew(Cluster cluster,
String serviceName,
RepositoryVersionEntity desiredRepositoryVersion)
Creates a new service in memory and then persists it to the database.
|
Config |
ConfigFactory.createNew(Cluster cluster,
String type,
String tag,
Map<String,String> map,
Map<String,Map<String,String>> mapAttributes)
Creates a new
Config object using provided values. |
Config |
ConfigFactory.createNew(StackId stackId,
Cluster cluster,
String type,
String tag,
Map<String,String> map,
Map<String,Map<String,String>> mapAttributes)
Creates a new
Config object using provided values. |
Map<String,Set<String>> |
ConfigHelper.createUserGroupsMap(Cluster cluster,
Map<String,DesiredConfig> desiredConfigs,
Map<String,ServiceInfo> servicesMap,
Set<PropertyInfo> stackProperties)
Fetch user to group mapping from the cluster configs.
|
Map<String,Set<String>> |
ConfigHelper.createUserGroupsMap(StackId stackId,
Cluster cluster,
Map<String,DesiredConfig> desiredConfigs)
Fetch user to group mapping from the cluster configs.
|
void |
ConfigHelper.getAndMergeHostConfigAttributes(Map<String,Map<String,Map<String,String>>> configurationAttributes,
Map<String,Map<String,String>> configurationTags,
Cluster cluster)
Retrieves effective configuration attributes for specified cluster and tags and merge them with
present before in
configurationAttributes |
void |
ConfigHelper.getAndMergeHostConfigs(Map<String,Map<String,String>> configurations,
Map<String,Map<String,String>> configurationTags,
Cluster cluster)
Retrieves effective configurations for specified cluster and tags and merge them with
present before in
configurations |
Map<String,Collection<String>> |
ConfigHelper.getChangedConfigTypes(Cluster cluster,
ServiceConfigEntity currentServiceConfigEntity,
Long configGroupId,
Long clusterId,
String serviceName)
Calculates config types and keys were changed during configs change.
|
Map<String,HostConfig> |
Host.getDesiredHostConfigs(Cluster cluster,
Map<String,DesiredConfig> clusterDesiredConfigs)
Get the desired configurations for the host including overrides
|
Map<String,Map<String,Map<String,String>>> |
ConfigHelper.getEffectiveConfigAttributes(Cluster cluster,
Map<String,Map<String,String>> desiredTags)
Get all config attributes for a cluster given a set of configType to
versionTags map.
|
Map<String,Map<String,String>> |
ConfigHelper.getEffectiveConfigProperties(Cluster cluster,
Map<String,Map<String,String>> desiredTags)
Get all config properties for a cluster given a set of configType to
versionTags map.
|
Map<String,Map<String,String>> |
ConfigHelper.getEffectiveDesiredTags(Cluster cluster,
String hostName)
Gets the desired tags for a cluster and host
|
Map<String,Map<String,String>> |
ConfigHelper.getEffectiveDesiredTags(Cluster cluster,
String hostName,
Map<String,DesiredConfig> desiredConfigs)
Gets the desired tags for a cluster and host
|
String |
ConfigHelper.getPlaceholderValueFromDesiredConfigurations(Cluster cluster,
String placeholder)
Gets the configuration value referenced by the specified placeholder from
the cluster configuration.
|
Map<PropertyInfo,String> |
ConfigHelper.getPropertiesWithPropertyType(PropertyInfo.PropertyType propertyType,
Cluster cluster,
Map<String,DesiredConfig> desiredConfigs,
Map<String,ServiceInfo> servicesMap,
Set<PropertyInfo> stackProperties)
Fetch all the properties of a given PropertyType.
|
Map<PropertyInfo,String> |
ConfigHelper.getPropertiesWithPropertyType(StackId stackId,
PropertyInfo.PropertyType propertyType,
Cluster cluster,
Map<String,DesiredConfig> desiredConfigs)
Fetch all the properties of a given PropertyType.
|
ServiceInfo |
ConfigHelper.getPropertyOwnerService(Cluster cluster,
String configType,
String propertyName) |
String |
ConfigHelper.getPropertyValueFromStackDefinitions(Cluster cluster,
String configType,
String propertyName)
Fetch all the config values of a given PropertyType.
|
Set<String> |
ConfigHelper.getPropertyValuesWithPropertyType(PropertyInfo.PropertyType propertyType,
Cluster cluster,
Map<String,DesiredConfig> desiredConfigs,
Map<String,ServiceInfo> servicesMap,
Set<PropertyInfo> stackProperties)
Fetch all the property values of a given PropertyType.
|
Set<String> |
ConfigHelper.getPropertyValuesWithPropertyType(StackId stackId,
PropertyInfo.PropertyType propertyType,
Cluster cluster,
Map<String,DesiredConfig> desiredConfigs)
Fetch all the property values of a given PropertyType.
|
String |
ConfigHelper.getRefreshConfigsCommand(Cluster cluster,
ServiceComponentHost sch) |
String |
ConfigHelper.getRefreshConfigsCommand(Cluster cluster,
String hostName,
String serviceName,
String componentName) |
Set<PropertyInfo> |
ConfigHelper.getServiceProperties(Cluster cluster,
String serviceName) |
Set<PropertyInfo> |
ConfigHelper.getStackProperties(Cluster cluster) |
String |
ConfigHelper.getValueFromDesiredConfigurations(Cluster cluster,
String configType,
String propertyName) |
void |
Clusters.invalidate(Cluster cluster)
Invalidates the specified cluster by retrieving it from the database and
refreshing all of the internal stateful collections.
|
void |
ConfigHelper.removeConfigsByType(Cluster cluster,
String type)
Remove configs by type
|
Set<ServiceComponent> |
ServiceComponentSupport.unsupportedComponents(Cluster cluster,
String stackName,
String stackVersion)
Collects the ServiceComponents from the cluster which are not supported (component doesn't exist or was deleted) in the given stack.
|
Set<String> |
ServiceComponentSupport.unsupportedServices(Cluster cluster,
String stackName,
String stackVersion)
Collects the service names from the cluster which are not supported (service doesn't exist or was deleted) in the given stack.
|
void |
ConfigHelper.updateConfigType(Cluster cluster,
StackId stackId,
AmbariManagementController controller,
String configType,
Map<String,String> updates,
Collection<String> removals,
String authenticatedUserName,
String serviceVersionNote)
A helper method to create a new
Config for a given configuration
type and updates to the current values, if any. |
Modifier and Type | Method and Description |
---|---|
Set<String> |
AlertDefinitionHash.getAssociatedHosts(Cluster cluster,
SourceType definitionSourceType,
String definitionName,
String definitionServiceName,
String definitionComponentName)
Gets the hosts that are associated with the specified definition.
|
Modifier and Type | Class and Description |
---|---|
class |
ClusterImpl |
Modifier and Type | Method and Description |
---|---|
Cluster |
ClusterFactory.create(ClusterEntity clusterEntity) |
protected Cluster |
ClustersImpl.findCluster(String name)
Find the cluster for the given name.
|
Cluster |
ClustersImpl.getCluster(Long clusterId) |
Cluster |
ClustersImpl.getCluster(String clusterName) |
Cluster |
ClustersImpl.getClusterById(long id) |
Modifier and Type | Method and Description |
---|---|
Map<String,Cluster> |
ClustersImpl.getClusters() |
Set<Cluster> |
ClustersImpl.getClustersForHost(String hostname) |
Modifier and Type | Method and Description |
---|---|
void |
ClustersImpl.invalidate(Cluster cluster)
Invalidates the specified cluster by retrieving it from the database and
refreshing all of the internal stateful collections.
|
Modifier and Type | Method and Description |
---|---|
ConfigGroup |
ConfigGroupFactory.createExisting(Cluster cluster,
ConfigGroupEntity entity)
Instantiates a
ConfigGroup from an existing, persisted entity. |
ConfigGroup |
ConfigGroupFactory.createNew(Cluster cluster,
String serviceName,
String name,
String tag,
String description,
Map<String,Config> configs,
Map<Long,Host> hosts)
Creates and saves a new
ConfigGroup . |
Constructor and Description |
---|
ConfigGroupImpl(Cluster cluster,
ConfigGroupEntity configGroupEntity,
Clusters clusters,
ConfigFactory configFactory,
ClusterDAO clusterDAO,
HostDAO hostDAO,
ConfigGroupDAO configGroupDAO,
ConfigGroupConfigMappingDAO configGroupConfigMappingDAO,
ConfigGroupHostMappingDAO configGroupHostMappingDAO,
LockFactory lockFactory) |
ConfigGroupImpl(Cluster cluster,
String serviceName,
String name,
String tag,
String description,
Map<String,Config> configurations,
Map<Long,Host> hosts,
Clusters clusters,
ConfigFactory configFactory,
ClusterDAO clusterDAO,
HostDAO hostDAO,
ConfigGroupDAO configGroupDAO,
ConfigGroupConfigMappingDAO configGroupConfigMappingDAO,
ConfigGroupHostMappingDAO configGroupHostMappingDAO,
LockFactory lockFactory) |
Modifier and Type | Method and Description |
---|---|
Map<String,HostConfig> |
HostImpl.getDesiredHostConfigs(Cluster cluster,
Map<String,DesiredConfig> clusterDesiredConfigs)
Get the desired configurations for the host including overrides
|
Modifier and Type | Method and Description |
---|---|
ClusterVersionSummary |
VersionDefinitionXml.getClusterSummary(Cluster cluster,
AmbariMetaInfo metaInfo)
Gets a summary for cluster given the version information in this version.
|
Set<String> |
VersionDefinitionXml.getMissingDependencies(Cluster cluster,
AmbariMetaInfo metaInfo)
Gets information about services which cannot be upgraded because the
repository does not contain required dependencies.
|
Modifier and Type | Method and Description |
---|---|
RequestExecution |
RequestExecutionFactory.createExisting(Cluster cluster,
RequestScheduleEntity requestScheduleEntity) |
RequestExecution |
RequestExecutionFactory.createNew(Cluster cluster,
Batch batch,
Schedule schedule) |
Constructor and Description |
---|
RequestExecutionImpl(Cluster cluster,
Batch batch,
Schedule schedule,
com.google.inject.Injector injector) |
RequestExecutionImpl(Cluster cluster,
RequestScheduleEntity requestScheduleEntity,
com.google.inject.Injector injector) |
Modifier and Type | Method and Description |
---|---|
RequestValidator |
RequestValidatorFactory.create(AddServiceRequest request,
Cluster cluster) |
RequestStatusResponse |
AddServiceOrchestrator.processAddServiceRequest(Cluster cluster,
AddServiceRequest request) |
Constructor and Description |
---|
RequestValidator(AddServiceRequest request,
Cluster cluster,
AmbariManagementController controller,
ConfigHelper configHelper,
StackFactory stackFactory,
KerberosDescriptorFactory kerberosDescriptorFactory,
SecurityConfigurationFactory securityConfigurationFactory) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,Cluster> |
AbstractUpgradeCatalog.getCheckedClusterMap(Clusters clusters)
This method returns Map of clusters.
|
Modifier and Type | Method and Description |
---|---|
protected void |
UpgradeCatalog260.fixYarnHsiKerberosDescriptorAndSiteConfig(Cluster cluster,
KerberosDescriptor kerberosDescriptor)
Updates YARN's NM 'llap_zk_hive' kerberos descriptor as reference and the associated config
hive-interactive-site/hive.llap.zk.sm.keytab.file
|
protected KerberosDescriptor |
AbstractUpgradeCatalog.getKerberosDescriptor(Cluster cluster)
Retrieve the composite Kerberos Descriptor.
|
protected static boolean |
AbstractUpgradeCatalog.isConfigEnabled(Cluster cluster,
String configType,
String propertyName) |
protected boolean |
AbstractUpgradeCatalog.isNNHAEnabled(Cluster cluster) |
protected boolean |
AbstractUpgradeCatalog.isQueueNameValid(Cluster cluster,
Set<String> validLeafQueues,
String queueNameProperty,
String configType)
Validate queueNameProperty exists for configType in cluster and corresponds to one of validLeafQueues
|
protected void |
AbstractUpgradeCatalog.removeConfigurationPropertiesFromCluster(Cluster cluster,
String configType,
Set<String> removePropertiesList)
Remove properties from the cluster
|
protected void |
AbstractUpgradeCatalog.updateConfigurationPropertiesForCluster(Cluster cluster,
String configType,
Map<String,String> properties,
boolean updateIfExists,
boolean createNewConfigType) |
protected void |
AbstractUpgradeCatalog.updateConfigurationPropertiesForCluster(Cluster cluster,
String configType,
Map<String,String> properties,
Set<String> removePropertiesList,
boolean updateIfExists,
boolean createNewConfigType)
Update properties for the cluster
|
protected void |
AbstractUpgradeCatalog.updateQueueName(Cluster cluster,
Set<String> validLeafQueues,
String queueNameProperty,
String configType)
Update property queueNameProperty from configType of cluster to first of validLeafQueues
|
Modifier and Type | Method and Description |
---|---|
static Set<Cluster> |
RetryHelper.getAffectedClusters() |
Modifier and Type | Method and Description |
---|---|
static void |
RetryHelper.addAffectedCluster(Cluster cluster) |
static Map<String,Set<String>> |
StageUtils.getClusterHostInfo(Cluster cluster) |
static void |
SecretReference.replaceReferencesWithPasswords(Map<String,String> targetMap,
Cluster cluster)
Replace secret references with appropriate real passwords.
|
Constructor and Description |
---|
SecretReference(String reference,
Cluster cluster) |
Constructor and Description |
---|
ClusterImpl(Cluster cluster)
Create a view associated cluster from an Ambari cluster.
|
Copyright © 2022 Apache Software Foundation. All rights reserved.