Modifier and Type | Method and Description |
---|---|
protected ClusterTopology |
ClusterBlueprintRenderer.createClusterTopology(TreeNode<Resource> clusterNode) |
Modifier and Type | Method and Description |
---|---|
void |
StackAdvisorBlueprintProcessor.adviseConfiguration(ClusterTopology clusterTopology,
Map<String,Map<String,String>> userProvidedConfigurations)
Recommend configurations by the stack advisor, then store the results in cluster topology.
|
Modifier and Type | Method and Description |
---|---|
Collection<String> |
UnitUpdater.getRequiredHostGroups(String propertyName,
String origValue,
Map<String,Map<String,String>> properties,
ClusterTopology topology) |
Collection<String> |
BlueprintConfigurationProcessor.PropertyUpdater.getRequiredHostGroups(String propertyName,
String origValue,
Map<String,Map<String,String>> properties,
ClusterTopology topology)
Determine the required host groups for the provided property.
|
Collection<String> |
BlueprintConfigurationProcessor.MultipleHostTopologyUpdater.getRequiredHostGroups(String propertyName,
String origValue,
Map<String,Map<String,String>> properties,
ClusterTopology topology) |
String |
UnitUpdater.updateForBlueprintExport(String propertyName,
String origValue,
Map<String,Map<String,String>> properties,
ClusterTopology topology) |
default String |
BlueprintConfigurationProcessor.PropertyUpdater.updateForBlueprintExport(String propertyName,
String value,
Map<String,Map<String,String>> properties,
ClusterTopology topology) |
String |
UnitUpdater.updateForClusterCreate(String propertyName,
String origValue,
Map<String,Map<String,String>> properties,
ClusterTopology topology) |
String |
BlueprintConfigurationProcessor.PropertyUpdater.updateForClusterCreate(String propertyName,
String origValue,
Map<String,Map<String,String>> properties,
ClusterTopology topology)
Update a property value.
|
String |
BlueprintConfigurationProcessor.MultipleHostTopologyUpdater.updateForClusterCreate(String propertyName,
String origValue,
Map<String,Map<String,String>> properties,
ClusterTopology topology)
Update all host names included in the original property value with new host names which run the associated
component.
|
Constructor and Description |
---|
BlueprintConfigurationProcessor(ClusterTopology clusterTopology) |
Modifier and Type | Class and Description |
---|---|
class |
ClusterTopologyImpl
Represents a cluster topology.
|
Modifier and Type | Method and Description |
---|---|
ClusterTopology |
TopologyManager.getClusterTopology(Long clusterId) |
Modifier and Type | Method and Description |
---|---|
Map<ClusterTopology,List<LogicalRequest>> |
PersistedState.getAllRequests()
Get all persisted requests.
|
Map<ClusterTopology,List<LogicalRequest>> |
PersistedStateImpl.getAllRequests() |
Modifier and Type | Method and Description |
---|---|
void |
AmbariContext.createAmbariResources(ClusterTopology topology,
String clusterName,
SecurityType securityType,
String repoVersionString,
Long repoVersionId) |
void |
AmbariContext.createAmbariServiceAndComponentResources(ClusterTopology topology,
String clusterName,
StackId stackId,
Long repositoryVersionId) |
protected LogicalRequest |
TopologyManager.createLogicalRequest(PersistedTopologyRequest request,
ClusterTopology topology,
Long requestId) |
LogicalRequest |
LogicalRequestFactory.createRequest(Long id,
TopologyRequest topologyRequest,
ClusterTopology topology) |
LogicalRequest |
LogicalRequestFactory.createRequest(Long id,
TopologyRequest topologyRequest,
ClusterTopology topology,
TopologyLogicalRequestEntity requestEntity) |
protected LogicalRequest |
TopologyManager.processAndPersistProvisionClusterTopologyRequest(ProvisionClusterRequest request,
ClusterTopology topology,
Long logicalRequestId)
Creates and persists a
PersistedTopologyRequest and a LogicalRequest for the provided
provision cluster request and topology. |
protected LogicalRequest |
TopologyManager.processAndPersistTopologyRequest(BaseClusterRequest request,
ClusterTopology topology,
Long logicalRequestId)
Creates and persists a
PersistedTopologyRequest and a LogicalRequest for the provided request and topology. |
void |
AmbariContext.registerHostWithConfigGroup(String hostName,
ClusterTopology topology,
String groupName) |
void |
ClusterConfigurationRequest.setConfigurationsOnCluster(ClusterTopology clusterTopology,
String tag,
Set<String> updatedConfigTypes)
Set all configurations on the cluster resource.
|
void |
TopologyValidator.validate(ClusterTopology topology) |
Constructor and Description |
---|
ClusterConfigurationRequest(AmbariContext ambariContext,
ClusterTopology clusterTopology,
boolean setInitial,
StackAdvisorBlueprintProcessor stackAdvisorBlueprintProcessor) |
ClusterConfigurationRequest(AmbariContext ambariContext,
ClusterTopology topology,
boolean setInitial,
StackAdvisorBlueprintProcessor stackAdvisorBlueprintProcessor,
boolean configureSecurity) |
HostRequest(long requestId,
long id,
long clusterId,
String hostname,
String blueprintName,
HostGroup hostGroup,
Predicate predicate,
ClusterTopology topology,
boolean skipFailure) |
HostRequest(long requestId,
long id,
String predicate,
ClusterTopology topology,
TopologyHostRequestEntity entity,
boolean skipFailure)
Only to be used when replaying persisted requests upon server startup.
|
LogicalRequest(Long id,
TopologyRequest request,
ClusterTopology topology) |
LogicalRequest(Long id,
TopologyRequest request,
ClusterTopology topology,
TopologyLogicalRequestEntity requestEntity) |
Modifier and Type | Method and Description |
---|---|
ConfigureClusterTask |
ConfigureClusterTaskFactory.createConfigureClusterTask(ClusterTopology topology,
ClusterConfigurationRequest configRequest,
AmbariEventPublisher ambariEventPublisher) |
Constructor and Description |
---|
ConfigureClusterTask(ClusterTopology topology,
ClusterConfigurationRequest configRequest,
AmbariEventPublisher ambariEventPublisher) |
InstallHostTask(ClusterTopology topology,
HostRequest hostRequest,
boolean skipFailure) |
PersistHostResourcesTask(ClusterTopology topology,
HostRequest hostRequest) |
RegisterWithConfigGroupTask(ClusterTopology topology,
HostRequest hostRequest) |
StartHostTask(ClusterTopology topology,
HostRequest hostRequest,
boolean skipFailure) |
TopologyHostTask(ClusterTopology topology,
HostRequest hostRequest) |
Modifier and Type | Method and Description |
---|---|
void |
UnitValidator.validate(ClusterTopology topology) |
void |
NameNodeHaValidator.validate(ClusterTopology topology) |
void |
HiveServiceValidator.validate(ClusterTopology topology) |
void |
RequiredConfigPropertiesValidator.validate(ClusterTopology topology)
Validates the configuration coming from the blueprint and cluster creation template and ensures that all the required properties are provided.
|
void |
ClusterConfigTypeValidator.validate(ClusterTopology topology) |
void |
StackConfigTypeValidator.validate(ClusterTopology topology) |
void |
RequiredPasswordValidator.validate(ClusterTopology topology)
Validate that all required password properties have been set or that 'default_password' is specified.
|
void |
ChainedTopologyValidator.validate(ClusterTopology topology) |
void |
NameNodeHaValidator.validateExternalNamenodeHa(ClusterTopology topology)
Verifies that all respective properties are set for an external NANENODE HA setup
|
void |
TopologyValidatorService.validateTopologyConfiguration(ClusterTopology clusterTopology) |
Copyright © 2022 Apache Software Foundation. All rights reserved.