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, com.google.inject.Injector injector)
ServiceComponentImpl(Service service, String componentName, com.google.inject.Injector injector)

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()
void	deleteAllServiceComponentHosts()
void	deleteServiceComponentHosts(String hostname)
ReadWriteLock	getClusterGlobalLock() Get lock to control access to cluster structure
long	getClusterId()
String	getClusterName()
StackId	getDesiredStackVersion()
State	getDesiredState()
String	getName()
ServiceComponentHost	getServiceComponentHost(String hostname)
Map<String,ServiceComponentHost>	getServiceComponentHosts()
String	getServiceName()
boolean	isClientComponent()
boolean	isMasterComponent()
boolean	isPersisted()
void	persist()
protected void	persistEntities()
void	refresh()
protected void	removeEntities()
void	setDesiredStackVersion(StackId stackVersion)
void	setDesiredState(State state)

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,
                            com.google.inject.Injector injector)
                     throws AmbariException

Throws:

AmbariException

ServiceComponentImpl

public ServiceComponentImpl(Service service,
                            ServiceComponentDesiredStateEntity serviceComponentDesiredStateEntity,
                            com.google.inject.Injector injector)
                     throws AmbariException

Throws:

AmbariException

Method Detail

getClusterGlobalLock

public ReadWriteLock getClusterGlobalLock()

Description copied from interface: ServiceComponent

Get lock to control access to cluster structure

Specified by:

getClusterGlobalLock in interface ServiceComponent

Returns:

cluster-global lock

getName

public String getName()

Specified by:

getName in interface ServiceComponent

getServiceName

public String getServiceName()

Specified by:

getServiceName 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

addServiceComponentHosts

public void addServiceComponentHosts(Map<String,ServiceComponentHost> hostComponents)
                              throws AmbariException

Specified by:

addServiceComponentHosts in interface ServiceComponent

Throws:

AmbariException

addServiceComponentHost

public void addServiceComponentHost(ServiceComponentHost hostComponent)
                             throws AmbariException

Specified by:

addServiceComponentHost in interface ServiceComponent

Throws:

AmbariException

addServiceComponentHost

public ServiceComponentHost addServiceComponentHost(String hostName)
                                             throws AmbariException

Specified by:

addServiceComponentHost in interface ServiceComponent

Throws:

AmbariException

getServiceComponentHost

public ServiceComponentHost getServiceComponentHost(String hostname)
                                             throws AmbariException

Specified by:

getServiceComponentHost in interface ServiceComponent

Throws:

AmbariException

getDesiredState

public State getDesiredState()

Specified by:

getDesiredState in interface ServiceComponent

setDesiredState

public void setDesiredState(State state)

Specified by:

setDesiredState in interface ServiceComponent

getDesiredStackVersion

public StackId getDesiredStackVersion()

Specified by:

getDesiredStackVersion in interface ServiceComponent

setDesiredStackVersion

public void setDesiredStackVersion(StackId stackVersion)

Specified by:

setDesiredStackVersion 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

isPersisted

public boolean isPersisted()

Specified by:

isPersisted in interface ServiceComponent

persist

public void persist()

Specified by:

persist in interface ServiceComponent

persistEntities

protected void persistEntities()

refresh

public void refresh()

Specified by:

refresh in interface ServiceComponent

isClientComponent

public boolean isClientComponent()

Specified by:

isClientComponent in interface ServiceComponent

isMasterComponent

public boolean isMasterComponent()

Specified by:

isMasterComponent in interface ServiceComponent

canBeRemoved

public boolean canBeRemoved()

Specified by:

canBeRemoved in interface ServiceComponent

deleteAllServiceComponentHosts

public void deleteAllServiceComponentHosts()
                                    throws AmbariException

Specified by:

deleteAllServiceComponentHosts in interface ServiceComponent

Throws:

AmbariException

deleteServiceComponentHosts

public void deleteServiceComponentHosts(String hostname)
                                 throws AmbariException

Specified by:

deleteServiceComponentHosts in interface ServiceComponent

Throws:

AmbariException

delete

public void delete()
            throws AmbariException

Specified by:

delete in interface ServiceComponent

Throws:

AmbariException

removeEntities

protected void removeEntities()
                       throws AmbariException

Throws:

AmbariException