Modifier and Type | Class and Description |
---|---|
class |
ClusterNotFoundException |
class |
ConfigGroupNotFoundException |
class |
DuplicateResourceException
Thrown when an attempt is made to create an already existing resource.
|
class |
HostNotFoundException |
class |
ObjectNotFoundException |
class |
ParentObjectNotFoundException
Indicates that a parent of a resource doesn't exist.
|
class |
ServiceComponentHostNotFoundException |
class |
ServiceComponentNotFoundException |
class |
ServiceNotFoundException |
class |
StackAccessException |
Modifier and Type | Method and Description |
---|---|
Request |
RequestFactory.createNew(long requestId,
Long clusterName) |
void |
ActionManager.sendActions(List<Stage> stages,
ExecuteActionRequest actionRequest) |
Constructor and Description |
---|
Request(Collection<Stage> stages,
ExecuteActionRequest actionRequest,
Clusters clusters,
com.google.gson.Gson gson) |
Modifier and Type | Method and Description |
---|---|
List<StatusCommand> |
HeartbeatMonitor.generateStatusCommands(String hostname) |
HeartBeatResponse |
HeartBeatHandler.handleHeartBeat(HeartBeat heartbeat) |
RegistrationResponse |
HeartBeatHandler.handleRegistration(Register register) |
protected void |
HeartBeatHandler.processCommandReports(HeartBeat heartbeat,
String hostname,
Clusters clusterFsm,
long now) |
protected void |
HeartBeatHandler.processHostStatus(HeartBeat heartbeat,
String hostname) |
protected void |
HeartBeatHandler.processStatusReports(HeartBeat heartbeat,
String hostname,
Clusters clusterFsm) |
protected void |
HeartBeatHandler.sendCommands(String hostname,
HeartBeatResponse response)
Adds commands from action queue to a heartbeat responce
|
Modifier and Type | Method and Description |
---|---|
void |
AmbariMetaInfo.addActionDefinition(ActionDefinition ad)
Used for test purposes
|
ComponentInfo |
AmbariMetaInfo.getComponent(String stackName,
String version,
String serviceName,
String componentName) |
ComponentInfo |
AmbariMetaInfo.getComponentCategory(String stackName,
String version,
String serviceName,
String componentName)
Get component category
|
List<ComponentInfo> |
AmbariMetaInfo.getComponentsByService(String stackName,
String version,
String serviceName)
Get components by service
|
String |
AmbariMetaInfo.getComponentToService(String stackName,
String version,
String componentName)
Get the name of a service given the component name.
|
List<MetricDefinition> |
AmbariMetaInfo.getMetrics(String stackName,
String stackVersion,
String serviceName,
String componentName,
String metricType)
Gets the metrics for a Role (component).
|
OperatingSystemInfo |
AmbariMetaInfo.getOperatingSystem(String stackName,
String version,
String osType) |
Set<OperatingSystemInfo> |
AmbariMetaInfo.getOperatingSystems(String stackName,
String version)
Lists operatingsystems supported by stack
|
Set<PropertyInfo> |
AmbariMetaInfo.getProperties(String stackName,
String version,
String serviceName) |
PropertyInfo |
AmbariMetaInfo.getProperty(String stackName,
String version,
String serviceName,
String propertyName) |
List<RepositoryInfo> |
AmbariMetaInfo.getRepositories(String stackName,
String version,
String osType) |
Map<String,List<RepositoryInfo>> |
AmbariMetaInfo.getRepository(String stackName,
String version) |
RepositoryInfo |
AmbariMetaInfo.getRepository(String stackName,
String version,
String osType,
String repoId) |
ServiceInfo |
AmbariMetaInfo.getService(String stackName,
String version,
String serviceName) |
ServiceInfo |
AmbariMetaInfo.getServiceInfo(String stackName,
String version,
String serviceName) |
Map<String,ServiceInfo> |
AmbariMetaInfo.getServices(String stackName,
String version)
Given a stack name and version return all the services with info
|
Stack |
AmbariMetaInfo.getStack(String stackName) |
StackInfo |
AmbariMetaInfo.getStackInfo(String stackName,
String version) |
Map<String,Map<String,String>> |
AmbariMetaInfo.getSupportedConfigs(String stackName,
String version,
String serviceName)
Get the service configs supported for a service in a particular stack
|
List<ServiceInfo> |
AmbariMetaInfo.getSupportedServices(String stackName,
String version) |
boolean |
AmbariMetaInfo.isSupportedStack(String stackName,
String version) |
boolean |
AmbariMetaInfo.isValidService(String stackName,
String version,
String serviceName) |
boolean |
AmbariMetaInfo.isValidServiceComponent(String stackName,
String version,
String serviceName,
String componentName) |
void |
AmbariMetaInfo.updateRepoBaseURL(String stackName,
String stackVersion,
String osType,
String repoId,
String newBaseUrl) |
Modifier and Type | Method and Description |
---|---|
String |
StackExtensionHelper.resolveHooksFolder(StackInfo stackInfo)
Determines exact hooks folder (subpath from stackRoot to hooks directory)
to use for a given stack.
|
Modifier and Type | Method and Description |
---|---|
void |
AmbariActionExecutionHelper.addExecutionCommandsToStage(ActionExecutionContext actionContext,
Stage stage,
Map<String,String> hostLevelParams)
Add tasks to the stage based on the requested action execution
|
void |
AmbariCustomCommandExecutionHelper.addExecutionCommandsToStage(ActionExecutionContext actionExecutionContext,
Stage stage,
Map<String,String> hostLevelParams)
Other than Service_Check and Decommission all other commands are pass-through
|
void |
AmbariCustomCommandExecutionHelper.addServiceCheckAction(Stage stage,
String hostname,
String smokeTestRole,
long nowTimestamp,
String serviceName,
String componentName,
Map<String,String> actionParameters,
Map<String,String> hostLevelParams)
Creates and populates service check EXECUTION_COMMAND for host.
|
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) |
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)
Add stages to the request.
|
protected void |
AmbariServer.checkDBVersion() |
RequestStatusResponse |
AmbariManagementControllerImpl.createAction(ExecuteActionRequest actionRequest,
Map<String,String> requestProperties) |
RequestStatusResponse |
AmbariManagementController.createAction(ExecuteActionRequest actionRequest,
Map<String,String> requestProperties)
Create the action defined by the attributes in the given request object.
|
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) |
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.
|
void |
AmbariManagementControllerImpl.createCluster(ClusterRequest request) |
void |
AmbariManagementController.createCluster(ClusterRequest request)
Create the cluster defined by the attributes in the given request object.
|
void |
AmbariManagementControllerImpl.createConfiguration(ConfigurationRequest request) |
void |
AmbariManagementController.createConfiguration(ConfigurationRequest request)
Creates a configuration.
|
void |
AmbariManagementControllerImpl.createHostComponents(Set<ServiceComponentHostRequest> requests) |
void |
AmbariManagementController.createHostComponents(Set<ServiceComponentHostRequest> requests)
Create the host component defined by the attributes in the given request object.
|
RequestStatusResponse |
MaintenanceStateHelper.createRequests(AmbariManagementController amc,
Map<String,String> requestProperties,
Set<String> clusterNames)
Creates the requests to send to the clusters
|
void |
AmbariManagementControllerImpl.createUsers(Set<UserRequest> requests) |
void |
AmbariManagementController.createUsers(Set<UserRequest> requests)
Creates users.
|
void |
AmbariManagementControllerImpl.deleteCluster(ClusterRequest request) |
void |
AmbariManagementController.deleteCluster(ClusterRequest request)
Delete the cluster identified by the given request object.
|
RequestStatusResponse |
AmbariManagementControllerImpl.deleteHostComponents(Set<ServiceComponentHostRequest> requests) |
RequestStatusResponse |
AmbariManagementController.deleteHostComponents(Set<ServiceComponentHostRequest> requests)
Delete the host component identified by the given request object.
|
void |
AmbariManagementControllerImpl.deleteUsers(Set<UserRequest> requests) |
void |
AmbariManagementController.deleteUsers(Set<UserRequest> requests)
Deletes the users specified.
|
Map<String,Map<String,String>> |
AmbariManagementControllerImpl.findConfigurationTagsWithOverrides(Cluster cluster,
String hostName) |
Map<String,Map<String,String>> |
AmbariManagementController.findConfigurationTagsWithOverrides(Cluster cluster,
String hostName)
Find configuration tags with applied overrides
|
Set<ClusterResponse> |
AmbariManagementControllerImpl.getClusters(Set<ClusterRequest> requests) |
Set<ClusterResponse> |
AmbariManagementController.getClusters(Set<ClusterRequest> requests)
Get the clusters identified by the given request objects.
|
Set<ConfigurationResponse> |
AmbariManagementControllerImpl.getConfigurations(Set<ConfigurationRequest> requests) |
Set<ConfigurationResponse> |
AmbariManagementController.getConfigurations(Set<ConfigurationRequest> requests)
Gets the configurations identified by the given request objects.
|
MaintenanceState |
AmbariManagementControllerImpl.getEffectiveMaintenanceState(ServiceComponentHost sch) |
MaintenanceState |
AmbariManagementController.getEffectiveMaintenanceState(ServiceComponentHost sch)
Gets the effective maintenance state for a host component
|
MaintenanceState |
MaintenanceStateHelper.getEffectiveState(ServiceComponentHost sch)
Gets the effective state for a HostComponent
|
MaintenanceState |
MaintenanceStateHelper.getEffectiveState(ServiceComponentHost sch,
Host host)
Get effective state of HostComponent
|
String |
AmbariManagementControllerImpl.getHealthyHost(Set<String> hostList) |
String |
AmbariManagementController.getHealthyHost(Set<String> hostList)
Return a healthy host if found otherwise any random host
|
Set<ServiceComponentHostResponse> |
AmbariManagementControllerImpl.getHostComponents(Set<ServiceComponentHostRequest> requests) |
Set<ServiceComponentHostResponse> |
AmbariManagementController.getHostComponents(Set<ServiceComponentHostRequest> requests)
Get the host components identified by the given request objects.
|
Set<Map<String,String>> |
MaintenanceStateHelper.getMaintenanceHostComponents(Clusters clusters,
Cluster cluster) |
String |
AmbariCustomCommandExecutionHelper.getRepoInfo(Cluster cluster,
Host host)
Get repository info given a cluster and host.
|
Set<RepositoryResponse> |
AmbariManagementControllerImpl.getRepositories(Set<RepositoryRequest> requests) |
Set<RepositoryResponse> |
AmbariManagementController.getRepositories(Set<RepositoryRequest> requests)
Get repositories by stack name, version and operating system.
|
abstract Set<RootServiceComponentResponse> |
AbstractRootServiceResponseFactory.getRootServiceComponents(RootServiceComponentRequest request)
Get all components of root services.
|
Set<RootServiceComponentResponse> |
AmbariManagementControllerImpl.getRootServiceComponents(Set<RootServiceComponentRequest> requests) |
Set<RootServiceComponentResponse> |
AmbariManagementController.getRootServiceComponents(Set<RootServiceComponentRequest> requests)
Get all components of top-level services of Ambari, not related to certain cluster.
|
abstract Set<RootServiceHostComponentResponse> |
AbstractRootServiceResponseFactory.getRootServiceHostComponent(RootServiceHostComponentRequest request,
Set<HostResponse> hosts)
Get all components of root services related to hosts.
|
Set<RootServiceHostComponentResponse> |
RootServiceResponseFactory.getRootServiceHostComponent(RootServiceHostComponentRequest request,
Set<HostResponse> hosts) |
abstract Set<RootServiceResponse> |
AbstractRootServiceResponseFactory.getRootServices(RootServiceRequest request)
Get all root services.
|
Set<RootServiceResponse> |
AmbariManagementControllerImpl.getRootServices(Set<RootServiceRequest> requests) |
Set<RootServiceResponse> |
AmbariManagementController.getRootServices(Set<RootServiceRequest> requests)
Get all top-level services of Ambari, not related to certain cluster.
|
Set<StackServiceComponentResponse> |
AmbariManagementControllerImpl.getStackComponents(Set<StackServiceComponentRequest> requests) |
Set<StackServiceComponentResponse> |
AmbariManagementController.getStackComponents(Set<StackServiceComponentRequest> requests)
Get components by stack name, version and service.
|
Set<StackConfigurationResponse> |
AmbariManagementControllerImpl.getStackConfigurations(Set<StackConfigurationRequest> requests) |
Set<StackConfigurationResponse> |
AmbariManagementController.getStackConfigurations(Set<StackConfigurationRequest> requests)
Get configurations by stack name, version and service.
|
Set<OperatingSystemResponse> |
AmbariManagementControllerImpl.getStackOperatingSystems(Set<OperatingSystemRequest> requests) |
Set<OperatingSystemResponse> |
AmbariManagementController.getStackOperatingSystems(Set<OperatingSystemRequest> requests)
Get operating systems by stack name, version.
|
Set<StackResponse> |
AmbariManagementControllerImpl.getStacks(Set<StackRequest> requests) |
Set<StackResponse> |
AmbariManagementController.getStacks(Set<StackRequest> requests)
Get supported stacks.
|
Set<StackServiceResponse> |
AmbariManagementControllerImpl.getStackServices(Set<StackServiceRequest> requests) |
Set<StackServiceResponse> |
AmbariManagementController.getStackServices(Set<StackServiceRequest> requests)
Get repositories by stack name, version.
|
Set<StackVersionResponse> |
AmbariManagementControllerImpl.getStackVersions(Set<StackVersionRequest> requests) |
Set<StackVersionResponse> |
AmbariManagementController.getStackVersions(Set<StackVersionRequest> requests)
Get supported stacks versions.
|
Set<TaskStatusResponse> |
AmbariManagementControllerImpl.getTaskStatus(Set<TaskStatusRequest> requests) |
Set<TaskStatusResponse> |
AmbariManagementController.getTaskStatus(Set<TaskStatusRequest> requests)
Gets the task status identified by the given request objects.
|
Set<UserResponse> |
AmbariManagementControllerImpl.getUsers(Set<UserRequest> requests) |
Set<UserResponse> |
AmbariManagementController.getUsers(Set<UserRequest> requests)
Gets the users identified by the given request objects.
|
boolean |
MaintenanceStateHelper.isOperationAllowed(Resource.Type sourceType,
ServiceComponentHost sch)
Determine based on the requesting Resource level and the state of the
operand whether to allow operations on it.
|
RequestStatusResponse |
AmbariManagementControllerImpl.updateClusters(Set<ClusterRequest> requests,
Map<String,String> requestProperties) |
RequestStatusResponse |
AmbariManagementController.updateClusters(Set<ClusterRequest> requests,
Map<String,String> requestProperties)
Update the cluster identified by the given request object with the
values carried by the given request object.
|
RequestStatusResponse |
AmbariManagementControllerImpl.updateHostComponents(Set<ServiceComponentHostRequest> requests,
Map<String,String> requestProperties,
boolean runSmokeTest) |
RequestStatusResponse |
AmbariManagementController.updateHostComponents(Set<ServiceComponentHostRequest> requests,
Map<String,String> requestProperties,
boolean runSmokeTest)
Update the host component identified by the given request object with the
values carried by the given request object.
|
void |
AmbariManagementControllerImpl.updateRespositories(Set<RepositoryRequest> requests) |
void |
AmbariManagementController.updateRespositories(Set<RepositoryRequest> requests)
Updates repositories by stack name, version and operating system.
|
RequestStatusResponse |
AmbariManagementControllerImpl.updateStacks() |
RequestStatusResponse |
AmbariManagementController.updateStacks()
Update stacks from the files at stackRoot.
|
void |
AmbariManagementControllerImpl.updateUsers(Set<UserRequest> requests) |
void |
AmbariManagementController.updateUsers(Set<UserRequest> requests)
Updates the users specified.
|
void |
AmbariActionExecutionHelper.validateAction(ExecuteActionRequest actionRequest)
Validates the request to execute an action.
|
void |
AmbariCustomCommandExecutionHelper.validateAction(ExecuteActionRequest actionRequest)
Validate custom command and throw exception is invalid request.
|
Modifier and Type | Method and Description |
---|---|
protected void |
ComponentResourceProvider.createComponents(Set<ServiceComponentRequest> requests) |
protected void |
HostResourceProvider.createHosts(Set<HostRequest> requests) |
protected void |
ServiceResourceProvider.createServices(Set<ServiceRequest> requests) |
protected RequestStatusResponse |
ComponentResourceProvider.deleteComponents() |
protected void |
HostResourceProvider.deleteHosts(Set<HostRequest> requests) |
protected RequestStatusResponse |
ServiceResourceProvider.deleteServices(Set<ServiceRequest> request) |
protected Set<ActionResponse> |
ActionResourceProvider.getActionDefinitions(Set<ActionRequest> requests) |
protected Set<ServiceComponentResponse> |
ComponentResourceProvider.getComponents(Set<ServiceComponentRequest> requests) |
protected static Set<HostResponse> |
HostResourceProvider.getHosts(AmbariManagementController controller,
HostRequest request) |
protected Set<HostResponse> |
HostResourceProvider.getHosts(Set<HostRequest> requests) |
protected Set<RootServiceHostComponentResponse> |
RootServiceHostComponentResourceProvider.getRootServiceHostComponents(Set<RootServiceHostComponentRequest> requests) |
protected Set<ServiceResponse> |
ServiceResourceProvider.getServices(Set<ServiceRequest> requests) |
T |
AbstractResourceProvider.Command.invoke()
Invoke this command.
|
protected RequestStatusResponse |
ComponentResourceProvider.updateComponents(Set<ServiceComponentRequest> requests,
Map<String,String> requestProperties,
boolean runSmokeTest) |
protected void |
HostResourceProvider.updateHosts(Set<HostRequest> requests,
Map<String,String> requestProperties) |
protected RequestStageContainer |
ServiceResourceProvider.updateServices(RequestStageContainer requestStages,
Set<ServiceRequest> requests,
Map<String,String> requestProperties,
boolean runSmokeTest,
boolean reconfigureClients) |
Modifier and Type | Method and Description |
---|---|
void |
ActionDefinitionManager.addActionDefinition(ActionDefinition ad) |
void |
ActionDefinitionManager.readCustomActionDefinitions(File customActionDefinitionRoot) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionScheduleManager.deleteAllJobs(RequestExecution requestExecution)
Delete all jobs and triggers if possible.
|
protected abstract void |
AbstractLinearExecutionJob.doWork(Map<String,Object> properties)
Do the actual work of the fired job.
|
Long |
ExecutionScheduleManager.executeBatchRequest(long executionId,
long batchId,
String clusterName)
Execute a Batch request and return request id if the server responds with
a request id for long running operations.
|
void |
ExecutionScheduleManager.finalizeBatch(long executionId,
String clusterName)
Marks Request Schedule as COMPLETED, if:
No triggers exist for the first job in the chain OR
If the trigger will never fire again.
|
protected abstract void |
AbstractLinearExecutionJob.finalizeExecution(Map<String,Object> properties) |
BatchRequestResponse |
ExecutionScheduleManager.getBatchRequestResponse(Long requestId,
String clusterName)
Get status of a long running operation
|
boolean |
ExecutionScheduleManager.hasToleranceThresholdExceeded(Long executionId,
String clusterName,
Map<String,Integer> taskCounts)
Check if the allowed threshold for failed tasks has exceeded.
|
void |
ExecutionScheduleManager.scheduleBatch(RequestExecution requestExecution)
Persist jobs based on the request batch and create trigger for the first
job
|
void |
ExecutionScheduler.startScheduler(Integer delay)
Initialize and start the scheduler to accept jobs.
|
void |
ExecutionSchedulerImpl.startScheduler(Integer delay) |
void |
ExecutionScheduler.stopScheduler()
Shutdown the scheduler threads and do not accept any more jobs.
|
void |
ExecutionSchedulerImpl.stopScheduler() |
void |
ExecutionScheduleManager.updateBatchRequest(long executionId,
long batchId,
String clusterName,
BatchRequestResponse batchRequestResponse,
boolean statusOnly) |
void |
ExecutionScheduleManager.updateBatchSchedule(RequestExecution requestExecution)
Delete and re-create all jobs and triggers
Update schedule for a batch
|
void |
ExecutionScheduleManager.validateSchedule(Schedule schedule)
Validate if schedule expression is a valid Cron schedule
|
Modifier and Type | Method and Description |
---|---|
void |
Users.addRoleToUser(User user,
String role) |
void |
Users.demoteAdmin(User user)
Removes ADMIN role form provided user
|
User |
Users.getLdapUser(String userName) |
User |
Users.getLocalUser(String userName) |
User |
Users.getUser(int userId) |
void |
Users.modifyPassword(String userName,
String currentUserPassword,
String newPassword)
Modifies password of local user
|
void |
Users.promoteToAdmin(User user)
Grants ADMIN role to provided user
|
void |
Users.removeRoleFromUser(User user,
String role) |
void |
Users.removeUser(User user) |
Modifier and Type | Method and Description |
---|---|
void |
CredentialProvider.addAliasToCredentialStore(String alias,
String passwordString) |
void |
CredentialStoreServiceImpl.addCredential(String alias,
String value) |
void |
CredentialStoreService.addCredential(String alias,
String key) |
void |
CredentialProvider.generateAliasWithPassword(String alias) |
char[] |
CredentialStoreServiceImpl.getCredential(String alias) |
char[] |
CredentialStoreService.getCredential(String alias) |
char[] |
CredentialProvider.getPasswordForAlias(String alias) |
protected KeyStore |
CredentialStoreServiceImpl.loadCredentialStore() |
Constructor and Description |
---|
CredentialProvider(String masterKey,
String masterKeyLocation,
boolean isMasterKeyPersisted) |
Modifier and Type | Method and Description |
---|---|
void |
ServerActionManagerImpl.executeAction(String actionName,
Map<String,String> payload) |
void |
ServerActionManager.executeAction(String actionName,
Map<String,String> payload) |
Modifier and Type | Method and Description |
---|---|
void |
Clusters.addCluster(String clusterName)
Add a new Cluster
|
void |
Cluster.addConfigGroup(ConfigGroup configGroup)
Add a new config group to the set of Config groups associated with this
cluster
|
void |
Clusters.addHost(String hostname)
Add a Host object to be managed by this server
|
void |
Cluster.addRequestExecution(RequestExecution requestExecution)
Add a @RequestExecution to the cluster
|
void |
Cluster.addService(Service service)
Add a service to a cluster
|
Service |
Cluster.addService(String serviceName)
Add service to the cluster
|
void |
ServiceImpl.addServiceComponent(ServiceComponent component) |
void |
Service.addServiceComponent(ServiceComponent component) |
ServiceComponent |
ServiceImpl.addServiceComponent(String serviceComponentName) |
ServiceComponent |
Service.addServiceComponent(String serviceComponentName) |
void |
ServiceComponent.addServiceComponentHost(ServiceComponentHost hostComponent) |
void |
ServiceComponentImpl.addServiceComponentHost(ServiceComponentHost hostComponent) |
ServiceComponentHost |
ServiceComponent.addServiceComponentHost(String hostName) |
ServiceComponentHost |
ServiceComponentImpl.addServiceComponentHost(String hostName) |
void |
ServiceComponent.addServiceComponentHosts(Map<String,ServiceComponentHost> hostComponents) |
void |
ServiceComponentImpl.addServiceComponentHosts(Map<String,ServiceComponentHost> hostComponents) |
void |
ServiceImpl.addServiceComponents(Map<String,ServiceComponent> components) |
void |
Service.addServiceComponents(Map<String,ServiceComponent> components) |
static void |
State.checkUpdateConfiguration(ServiceComponentHost serviceComponentHost,
State currentState,
State desiredState)
Determine whether or not it is safe to update the configuration of the given service
component host for the given states.
|
ClusterResponse |
Cluster.convertToResponse()
Creates a cluster response based on the current cluster definition
|
void |
ServiceComponent.delete() |
void |
ServiceImpl.delete() |
void |
Service.delete() |
void |
ServiceComponentHost.delete() |
void |
Cluster.delete()
Delete the cluster
|
void |
ServiceComponentImpl.delete() |
void |
ServiceImpl.deleteAllComponents() |
void |
Service.deleteAllComponents() |
void |
ServiceComponent.deleteAllServiceComponentHosts() |
void |
ServiceComponentImpl.deleteAllServiceComponentHosts() |
void |
Cluster.deleteAllServices()
Delete all the services associated with this cluster
|
void |
Clusters.deleteCluster(String clusterName)
Deletes the cluster identified by the name
|
void |
Cluster.deleteConfigGroup(Long id)
Delete this config group identified by the config group id
|
void |
Clusters.deleteHost(String hostname)
Removes a host.
|
void |
Cluster.deleteRequestExecution(Long id)
Delete a @RequestExecution associated with the cluster
|
void |
Cluster.deleteService(String serviceName)
Delete the named service associated with this cluster
|
void |
ServiceImpl.deleteServiceComponent(String componentName) |
void |
Service.deleteServiceComponent(String componentName) |
void |
ServiceComponent.deleteServiceComponentHosts(String hostname) |
void |
ServiceComponentImpl.deleteServiceComponentHosts(String hostname) |
Cluster |
Clusters.getCluster(String clusterName)
Gets the Cluster given the cluster name
|
Cluster |
Clusters.getClusterById(long id)
Gets the cluster using the id.
|
Set<Cluster> |
Clusters.getClustersForHost(String hostname)
Returns all the cluster names for this hostname
|
Map<Long,ConfigGroup> |
Cluster.getConfigGroups()
Get all config groups associated with this cluster
|
Map<Long,ConfigGroup> |
Cluster.getConfigGroupsByHostname(String hostname)
Find all config groups associated with the give hostname
|
Map<String,HostConfig> |
Host.getDesiredHostConfigs(Cluster cluster)
Get the desired configurations for the host including overrides
|
Map<String,Map<String,String>> |
ConfigHelper.getEffectiveDesiredTags(Cluster cluster,
String hostName)
Gets the desired tags for a cluster and host
|
Host |
Clusters.getHost(String hostname)
Get a Host object managed by this server
|
Map<String,Host> |
Clusters.getHostsForCluster(String clusterName)
Gets all the hosts associated with the cluster
|
Service |
Cluster.getService(String serviceName)
Get a service
|
ServiceComponent |
ServiceImpl.getServiceComponent(String componentName) |
ServiceComponent |
Service.getServiceComponent(String componentName) |
ServiceComponentHost |
ServiceComponent.getServiceComponentHost(String hostname) |
ServiceComponentHost |
ServiceComponentImpl.getServiceComponentHost(String hostname) |
boolean |
ConfigHelper.isStaleConfigs(ServiceComponentHost sch)
The purpose of this method is to determine if a
ServiceComponentHost 's
known actual configs are different than what is set on the cluster (the desired). |
void |
Clusters.mapHostsToCluster(Set<String> hostnames,
String clusterName)
Maps a set of hosts to the given cluster
|
void |
Clusters.mapHostToCluster(String hostname,
String clusterName)
Map host to the given cluster.
|
protected void |
ServiceImpl.removeEntities() |
protected void |
ServiceComponentImpl.removeEntities() |
void |
Cluster.removeServiceComponentHost(ServiceComponentHost svcCompHost)
Remove ServiceComponentHost from cluster
|
void |
Cluster.setCurrentStackVersion(StackId stackVersion)
Set current stack version
|
void |
Clusters.setCurrentStackVersion(String clusterName,
StackId stackId)
Sets the current stack version for the cluster
|
void |
Clusters.unmapHostFromCluster(String hostname,
String clusterName)
Removes a host from a cluster.
|
void |
Clusters.updateHostWithClusterAndAttributes(Map<String,Set<String>> hostsClusters,
Map<String,Map<String,String>> hostAttributes)
Update the host set for clusters and the host attributes associated with the hosts
|
Constructor and Description |
---|
ServiceComponentImpl(Service service,
ServiceComponentDesiredStateEntity serviceComponentDesiredStateEntity,
com.google.inject.Injector injector) |
ServiceComponentImpl(Service service,
String componentName,
com.google.inject.Injector injector) |
ServiceImpl(Cluster cluster,
ClusterServiceEntity serviceEntity,
com.google.inject.Injector injector) |
ServiceImpl(Cluster cluster,
String serviceName,
com.google.inject.Injector injector) |
Modifier and Type | Method and Description |
---|---|
void |
ClustersImpl.addCluster(String clusterName) |
void |
ClusterImpl.addConfigGroup(ConfigGroup configGroup) |
void |
ClustersImpl.addHost(String hostname) |
void |
ClusterImpl.addRequestExecution(RequestExecution requestExecution) |
void |
ClusterImpl.addService(Service service) |
Service |
ClusterImpl.addService(String serviceName) |
void |
ClusterImpl.addServiceComponentHost(ServiceComponentHost svcCompHost) |
ClusterResponse |
ClusterImpl.convertToResponse() |
void |
ClusterImpl.delete() |
void |
ClusterImpl.deleteAllServices() |
void |
ClustersImpl.deleteCluster(String clusterName) |
void |
ClusterImpl.deleteConfigGroup(Long id) |
void |
ClustersImpl.deleteHost(String hostname) |
void |
ClusterImpl.deleteRequestExecution(Long id) |
void |
ClusterImpl.deleteService(String serviceName) |
Cluster |
ClustersImpl.getCluster(String clusterName) |
Cluster |
ClustersImpl.getClusterById(long id) |
Set<Cluster> |
ClustersImpl.getClustersForHost(String hostname) |
Map<Long,ConfigGroup> |
ClusterImpl.getConfigGroups() |
Map<Long,ConfigGroup> |
ClusterImpl.getConfigGroupsByHostname(String hostname) |
Host |
ClustersImpl.getHost(String hostname) |
Map<String,Host> |
ClustersImpl.getHostsForCluster(String clusterName) |
Service |
ClusterImpl.getService(String serviceName) |
ServiceComponentHost |
ClusterImpl.getServiceComponentHost(String serviceName,
String serviceComponentName,
String hostname) |
void |
ClustersImpl.mapHostsToCluster(Set<String> hostnames,
String clusterName) |
void |
ClustersImpl.mapHostToCluster(String hostname,
String clusterName) |
protected void |
ClusterImpl.removeEntities() |
void |
ClusterImpl.removeServiceComponentHost(ServiceComponentHost svcCompHost) |
void |
ClusterImpl.setCurrentStackVersion(StackId stackVersion) |
void |
ClustersImpl.setCurrentStackVersion(String clusterName,
StackId stackId) |
void |
ClustersImpl.unmapHostFromCluster(String hostname,
String clusterName) |
void |
ClustersImpl.updateHostWithClusterAndAttributes(Map<String,Set<String>> hostClusters,
Map<String,Map<String,String>> hostAttributes) |
Modifier and Type | Method and Description |
---|---|
void |
ConfigGroup.addConfiguration(Config config)
Add config to the config group
|
void |
ConfigGroupImpl.addConfiguration(Config config) |
void |
ConfigGroup.addHost(Host host)
Add host to Config group
|
void |
ConfigGroupImpl.addHost(Host host) |
ConfigGroupResponse |
ConfigGroup.convertToResponse()
Return @ConfigGroupResponse for the config group
|
ConfigGroupResponse |
ConfigGroupImpl.convertToResponse() |
void |
ConfigGroup.removeHost(String hostname)
Remove host mapping
|
void |
ConfigGroupImpl.removeHost(String hostname) |
Modifier and Type | Method and Description |
---|---|
Map<String,HostConfig> |
HostImpl.getDesiredHostConfigs(Cluster cluster)
Get a map of configType with all applicable config tags.
|
Modifier and Type | Method and Description |
---|---|
protected void |
BatchRequestJob.doWork(Map<String,Object> properties) |
protected void |
BatchRequestJob.finalizeExecution(Map<String,Object> properties) |
Modifier and Type | Method and Description |
---|---|
void |
UpgradeCatalog150.executeDDLUpdates() |
protected abstract void |
AbstractUpgradeCatalog.executeDDLUpdates() |
protected void |
UpgradeCatalog151.executeDDLUpdates() |
void |
UpgradeCatalog150.executeDMLUpdates() |
protected abstract void |
AbstractUpgradeCatalog.executeDMLUpdates() |
void |
UpgradeCatalog151.executeDMLUpdates() |
void |
SchemaUpgradeHelper.executeDMLUpdates(List<UpgradeCatalog> upgradeCatalogs) |
void |
SchemaUpgradeHelper.executeUpgrade(List<UpgradeCatalog> upgradeCatalogs) |
protected List<UpgradeCatalog> |
SchemaUpgradeHelper.getUpgradePath(String sourceVersion,
String targetVersion)
Return a set Upgrade catalogs to be applied to upgrade from
|
void |
AbstractUpgradeCatalog.upgradeData() |
void |
UpgradeCatalog.upgradeData()
perform data updates as necessary, requires started persist service
|
void |
AbstractUpgradeCatalog.upgradeSchema() |
void |
UpgradeCatalog.upgradeSchema()
Run the upgrade scripts for upgrading ambari server from current version
to the new version.
|
Modifier and Type | Method and Description |
---|---|
static Map<String,Set<String>> |
StageUtils.getClusterHostInfo(Map<String,Host> allHosts,
Cluster cluster) |
Copyright © 2015. All rights reserved.