org.apache.ambari.server.state

Class ServiceComponentImpl

java.lang.Object

org.apache.ambari.server.state.ServiceComponentImpl

All Implemented Interfaces:

ServiceComponent

public class ServiceComponentImpl
extends Object
implements ServiceComponent

Constructor Summary

Constructors

Constructor and Description
ServiceComponentImpl(Service service, ServiceComponentDesiredStateEntity serviceComponentDesiredStateEntity, AmbariMetaInfo ambariMetaInfo, ServiceComponentDesiredStateDAO serviceComponentDesiredStateDAO, ClusterServiceDAO clusterServiceDAO, HostComponentDesiredStateDAO hostComponentDesiredStateDAO, ServiceComponentHostFactory serviceComponentHostFactory, AmbariEventPublisher eventPublisher)
ServiceComponentImpl(Service service, String componentName, AmbariMetaInfo ambariMetaInfo, ServiceComponentDesiredStateDAO serviceComponentDesiredStateDAO, ClusterServiceDAO clusterServiceDAO, ServiceComponentHostFactory serviceComponentHostFactory, AmbariEventPublisher eventPublisher)

Method Summary

Modifier and Type	Method and Description
void	addServiceComponentHost(ServiceComponentHost hostComponent)
ServiceComponentHost	addServiceComponentHost(String hostName)
void	addServiceComponentHosts(Map<String,ServiceComponentHost> hostComponents)
boolean	canBeRemoved()
ServiceComponentResponse	convertToResponse()
void	debugDump(StringBuilder sb)
void	delete(DeleteHostComponentStatusMetaData deleteMetaData)
void	deleteAllServiceComponentHosts(DeleteHostComponentStatusMetaData deleteMetaData)
void	deleteServiceComponentHosts(String hostname, DeleteHostComponentStatusMetaData deleteMetaData)
long	getClusterId()
String	getClusterName()
RepositoryVersionEntity	getDesiredRepositoryVersion() Gets the desired repository for this service component.
StackId	getDesiredStackId()
State	getDesiredState()
String	getDesiredVersion()
String	getDisplayName()
String	getName()
RepositoryVersionState	getRepositoryState()
ServiceComponentHost	getServiceComponentHost(String hostname)
Map<String,ServiceComponentHost>	getServiceComponentHosts()
Set<String>	getServiceComponentsHosts()
String	getServiceName()
boolean	isClientComponent()
boolean	isMasterComponent()
boolean	isRecoveryEnabled() Get the recoveryEnabled value.
boolean	isVersionAdvertised()
protected void	persistEntities(ServiceComponentDesiredStateEntity desiredStateEntity)
void	setDesiredRepositoryVersion(RepositoryVersionEntity repositoryVersionEntity)
void	setDesiredState(State state)
void	setRecoveryEnabled(boolean recoveryEnabled) Set the recoveryEnabled field in the entity object.
void	updateComponentInfo() Refresh Component info due to current stack
void	updateRepositoryState(String reportedVersion) Follows this version logic: DB hostcomponent1 DB hostcomponentN DB desired New desired Repo State v1 v1 UNKNOWN v1 CURRENT v1 v2 UNKNOWN UNKNOWN OUT_OF_SYNC v1 v2 v2 v2 (no change) OUT_OF_SYNC v2 v2 v1 v1 (no change) OUT_OF_SYNC v2 v2 v2 v2 (no change) CURRENT Methods inherited from class java.lang.Object clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait Constructor Detail ServiceComponentImpl public ServiceComponentImpl(Service service, String componentName, AmbariMetaInfo ambariMetaInfo, ServiceComponentDesiredStateDAO serviceComponentDesiredStateDAO, ClusterServiceDAO clusterServiceDAO, ServiceComponentHostFactory serviceComponentHostFactory, AmbariEventPublisher eventPublisher) throws org.apache.ambari.server.AmbariException Throws: org.apache.ambari.server.AmbariException ServiceComponentImpl public ServiceComponentImpl(Service service, ServiceComponentDesiredStateEntity serviceComponentDesiredStateEntity, AmbariMetaInfo ambariMetaInfo, ServiceComponentDesiredStateDAO serviceComponentDesiredStateDAO, ClusterServiceDAO clusterServiceDAO, HostComponentDesiredStateDAO hostComponentDesiredStateDAO, ServiceComponentHostFactory serviceComponentHostFactory, AmbariEventPublisher eventPublisher) throws org.apache.ambari.server.AmbariException Throws: org.apache.ambari.server.AmbariException Method Detail updateComponentInfo public void updateComponentInfo() throws org.apache.ambari.server.AmbariException Description copied from interface: ServiceComponent Refresh Component info due to current stack Specified by: updateComponentInfo in interface ServiceComponent Throws: org.apache.ambari.server.AmbariException getName public String getName() Specified by: getName in interface ServiceComponent isRecoveryEnabled public boolean isRecoveryEnabled() Get the recoveryEnabled value. Specified by: isRecoveryEnabled in interface ServiceComponent Returns: true or false setRecoveryEnabled public void setRecoveryEnabled(boolean recoveryEnabled) Set the recoveryEnabled field in the entity object. Specified by: setRecoveryEnabled in interface ServiceComponent Parameters: recoveryEnabled - - true or false getServiceName public String getServiceName() Specified by: getServiceName in interface ServiceComponent getDisplayName public String getDisplayName() Specified by: getDisplayName in interface ServiceComponent getClusterId public long getClusterId() Specified by: getClusterId in interface ServiceComponent getServiceComponentHosts public Map<String,ServiceComponentHost> getServiceComponentHosts() Specified by: getServiceComponentHosts in interface ServiceComponent getServiceComponentsHosts public Set<String> getServiceComponentsHosts() Specified by: getServiceComponentsHosts in interface ServiceComponent addServiceComponentHosts public void addServiceComponentHosts(Map<String,ServiceComponentHost> hostComponents) throws org.apache.ambari.server.AmbariException Specified by: addServiceComponentHosts in interface ServiceComponent Throws: org.apache.ambari.server.AmbariException addServiceComponentHost public void addServiceComponentHost(ServiceComponentHost hostComponent) throws org.apache.ambari.server.AmbariException Specified by: addServiceComponentHost in interface ServiceComponent Throws: org.apache.ambari.server.AmbariException addServiceComponentHost public ServiceComponentHost addServiceComponentHost(String hostName) throws org.apache.ambari.server.AmbariException Specified by: addServiceComponentHost in interface ServiceComponent Throws: org.apache.ambari.server.AmbariException getServiceComponentHost public ServiceComponentHost getServiceComponentHost(String hostname) throws org.apache.ambari.server.AmbariException Specified by: getServiceComponentHost in interface ServiceComponent Throws: org.apache.ambari.server.AmbariException getDesiredState public State getDesiredState() Specified by: getDesiredState in interface ServiceComponent setDesiredState public void setDesiredState(State state) Specified by: setDesiredState in interface ServiceComponent getDesiredStackId public StackId getDesiredStackId() Specified by: getDesiredStackId in interface ServiceComponent setDesiredRepositoryVersion public void setDesiredRepositoryVersion(RepositoryVersionEntity repositoryVersionEntity) Specified by: setDesiredRepositoryVersion in interface ServiceComponent getDesiredRepositoryVersion public RepositoryVersionEntity getDesiredRepositoryVersion() Gets the desired repository for this service component. Specified by: getDesiredRepositoryVersion in interface ServiceComponent Returns: getDesiredVersion public String getDesiredVersion() Specified by: getDesiredVersion in interface ServiceComponent convertToResponse public ServiceComponentResponse convertToResponse() Specified by: convertToResponse in interface ServiceComponent getClusterName public String getClusterName() Specified by: getClusterName in interface ServiceComponent debugDump public void debugDump(StringBuilder sb) Specified by: debugDump in interface ServiceComponent persistEntities protected void persistEntities(ServiceComponentDesiredStateEntity desiredStateEntity) isClientComponent public boolean isClientComponent() Specified by: isClientComponent in interface ServiceComponent isMasterComponent public boolean isMasterComponent() Specified by: isMasterComponent in interface ServiceComponent isVersionAdvertised public boolean isVersionAdvertised() Specified by: isVersionAdvertised in interface ServiceComponent canBeRemoved public boolean canBeRemoved() Specified by: canBeRemoved in interface ServiceComponent deleteAllServiceComponentHosts public void deleteAllServiceComponentHosts(DeleteHostComponentStatusMetaData deleteMetaData) Specified by: deleteAllServiceComponentHosts in interface ServiceComponent deleteServiceComponentHosts public void deleteServiceComponentHosts(String hostname, DeleteHostComponentStatusMetaData deleteMetaData) throws org.apache.ambari.server.AmbariException Specified by: deleteServiceComponentHosts in interface ServiceComponent Throws: org.apache.ambari.server.AmbariException delete public void delete(DeleteHostComponentStatusMetaData deleteMetaData) Specified by: delete in interface ServiceComponent updateRepositoryState public void updateRepositoryState(String reportedVersion) throws org.apache.ambari.server.AmbariException Follows this version logic: DB hostcomponent1 DB hostcomponentN DB desired New desired Repo State v1 v1 UNKNOWN v1 CURRENT v1 v2 UNKNOWN UNKNOWN OUT_OF_SYNC v1 v2 v2 v2 (no change) OUT_OF_SYNC v2 v2 v1 v1 (no change) OUT_OF_SYNC v2 v2 v2 v2 (no change) CURRENT Specified by: updateRepositoryState in interface ServiceComponent Throws: org.apache.ambari.server.AmbariException getRepositoryState public RepositoryVersionState getRepositoryState() Specified by: getRepositoryState in interface ServiceComponent Returns: the repository state for the desired version Skip navigation links Overview Package Class Use Tree Deprecated Index Help Prev Class Next Class Frames No Frames All Classes Summary: Nested | Field | Constr | Method Detail: Field | Constr | Method Copyright © 2022 Apache Software Foundation. All rights reserved.