org.apache.ambari.server.topology.addservice

Class ResourceProviderAdapter

java.lang.Object

org.apache.ambari.server.topology.addservice.ResourceProviderAdapter

@Singleton
public class ResourceProviderAdapter
extends Object

Creates resources using the resource providers. Translates AddServiceInfo to internal requests accepted by those.

Constructor Summary

Constructors

Constructor and Description
ResourceProviderAdapter()

Method Summary

Modifier and Type	Method and Description
void	createComponents(AddServiceInfo request)
void	createConfigs(AddServiceInfo request)
static Map<String,Object>	createCredentialRequestProperties(String clusterName, Credential credential)
void	createCredentials(AddServiceInfo request)
void	createHostComponents(AddServiceInfo request)
void	createKerberosDescriptor(AddServiceInfo request, KerberosDescriptor descriptor)
static Map<String,Object>	createKerberosDescriptorRequestProperties(String clusterName)
void	createServices(AddServiceInfo request)
Optional<KerberosDescriptor>	getKerberosDescriptor(AddServiceInfo request)
static Predicate	predicateForKerberosDescriptorArtifact(String clusterName)
static Map<String,String>	requestInfoForKerberosDescriptor(KerberosDescriptor descriptor)
void	updateExistingConfigs(AddServiceInfo request, Set<String> existingServices)
void	updateHostComponentDesiredState(AddServiceInfo request, Predicate predicate, ProvisionStep step)
void	updateKerberosDescriptor(AddServiceInfo request, KerberosDescriptor descriptor)
void	updateServiceDesiredState(AddServiceInfo request, State desiredState)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ResourceProviderAdapter

public ResourceProviderAdapter()

Method Detail

createServices

public void createServices(AddServiceInfo request)

createComponents

public void createComponents(AddServiceInfo request)

createHostComponents

public void createHostComponents(AddServiceInfo request)

createConfigs

public void createConfigs(AddServiceInfo request)

createCredentials

public void createCredentials(AddServiceInfo request)

getKerberosDescriptor

public Optional<KerberosDescriptor> getKerberosDescriptor(AddServiceInfo request)

Returns:

Optional with the cluster's kerberos descriptor artifact if it exists, otherwise empty Optional

createKerberosDescriptor

public void createKerberosDescriptor(AddServiceInfo request,
                                     KerberosDescriptor descriptor)

updateKerberosDescriptor

public void updateKerberosDescriptor(AddServiceInfo request,
                                     KerberosDescriptor descriptor)

updateExistingConfigs

public void updateExistingConfigs(AddServiceInfo request,
                                  Set<String> existingServices)

updateServiceDesiredState

public void updateServiceDesiredState(AddServiceInfo request,
                                      State desiredState)

updateHostComponentDesiredState

public void updateHostComponentDesiredState(AddServiceInfo request,
                                            Predicate predicate,
                                            ProvisionStep step)

requestInfoForKerberosDescriptor

public static Map<String,String> requestInfoForKerberosDescriptor(KerberosDescriptor descriptor)

createCredentialRequestProperties

public static Map<String,Object> createCredentialRequestProperties(String clusterName,
                                                                   Credential credential)

createKerberosDescriptorRequestProperties

public static Map<String,Object> createKerberosDescriptorRequestProperties(String clusterName)

predicateForKerberosDescriptorArtifact

public static Predicate predicateForKerberosDescriptorArtifact(String clusterName)