org.apache.ambari.server.state.svccomphost

Class ServiceComponentHostImpl

java.lang.Object

org.apache.ambari.server.state.svccomphost.ServiceComponentHostImpl

All Implemented Interfaces:

ServiceComponentHost

public class ServiceComponentHostImpl
extends Object
implements ServiceComponentHost

Constructor Summary

Constructors

Constructor and Description
ServiceComponentHostImpl(ServiceComponent serviceComponent, HostComponentStateEntity stateEntity, HostComponentDesiredStateEntity desiredStateEntity, Clusters clusters, StackDAO stackDAO, HostDAO hostDAO, ServiceComponentDesiredStateDAO serviceComponentDesiredStateDAO, HostComponentStateDAO hostComponentStateDAO, HostComponentDesiredStateDAO hostComponentDesiredStateDAO, AmbariEventPublisher eventPublisher)
ServiceComponentHostImpl(ServiceComponent serviceComponent, String hostName, Clusters clusters, StackDAO stackDAO, HostDAO hostDAO, ServiceComponentDesiredStateDAO serviceComponentDesiredStateDAO, HostComponentStateDAO hostComponentStateDAO, HostComponentDesiredStateDAO hostComponentDesiredStateDAO, AmbariEventPublisher eventPublisher)
ServiceComponentHostImpl(ServiceComponent serviceComponent, String hostName, ServiceComponentDesiredStateEntity serviceComponentDesiredStateEntity, Clusters clusters, StackDAO stackDAO, HostDAO hostDAO, ServiceComponentDesiredStateDAO serviceComponentDesiredStateDAO, HostComponentStateDAO hostComponentStateDAO, HostComponentDesiredStateDAO hostComponentDesiredStateDAO, AmbariEventPublisher eventPublisher)

Method Summary

Modifier and Type	Method and Description
boolean	canBeRemoved()
ServiceComponentHostResponse	convertToResponse(Map<String,DesiredConfig> desiredConfigs) Builds a ServiceComponentHostResponse.
ServiceComponentHostResponse	convertToResponseStatusOnly(Map<String,DesiredConfig> desiredConfigs, boolean collectStaleConfigsStatus)
void	debugDump(StringBuilder sb)
void	delete(DeleteHostComponentStatusMetaData deleteMetaData)
Map<String,HostConfig>	getActualConfigs() Gets the actual config tags, if known.
long	getClusterId() Get the Cluster that this object maps to
String	getClusterName() Get the Cluster that this object maps to
HostComponentAdminState	getComponentAdminState()
StackId	getDesiredStackId() Convenience method to get the desired stack id from the service component
State	getDesiredState()
HostComponentDesiredStateEntity	getDesiredStateEntity() Gets the desired state entity for this ServiceComponentHost.
Host	getHost() Get the Host this object maps to
String	getHostName() Get the Host this object maps to
HostState	getHostState()
long	getLastOpEndTime()
long	getLastOpLastUpdateTime()
long	getLastOpStartTime()
MaintenanceState	getMaintenanceState()
List<Map<String,String>>	getProcesses()
String	getPublicHostName() Get the public host name this object maps to
ServiceComponent	getServiceComponent() Gets the service component.
String	getServiceComponentName() Get the ServiceComponent this object maps to
String	getServiceName() Get the Service this object maps to
State	getState()
UpgradeState	getUpgradeState()
String	getVersion() Gets the version of the component.
void	handleEvent(ServiceComponentHostEvent event) Send a ServiceComponentHostState event to the StateMachine
boolean	isClientComponent()
boolean	isRecoveryEnabled() Get whether recovery is enabled for this component or not.
boolean	isRestartRequired()
boolean	isRestartRequired(HostComponentDesiredStateEntity hostComponentDesiredStateEntity)
HostVersionEntity	recalculateHostVersionState() Updates an existing HostVersionEntity for the desired repository of this component, or create one if it doesn't exist.
protected void	removeEntities()
void	setComponentAdminState(HostComponentAdminState attribute)
void	setDesiredState(State state)
void	setLastOpEndTime(long lastOpEndTime)
void	setLastOpLastUpdateTime(long lastOpLastUpdateTime)
void	setLastOpStartTime(long lastOpStartTime)
void	setMaintenanceState(MaintenanceState state)
void	setProcesses(List<Map<String,String>> procs)
void	setRestartRequired(boolean restartRequired)
boolean	setRestartRequiredWithoutEventPublishing(boolean restartRequired) Set restartRequired flag for appropriate HostComponentDesiredStateEntity
void	setState(State state)
void	setUpgradeState(UpgradeState upgradeState) To be called during the upgrade of a specific Component in a host.
void	setVersion(String version) Sets the version of the component from the stack.

Methods inherited from class java.lang.Object

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

Constructor Detail

ServiceComponentHostImpl

public ServiceComponentHostImpl(ServiceComponent serviceComponent,
                                String hostName,
                                ServiceComponentDesiredStateEntity serviceComponentDesiredStateEntity,
                                Clusters clusters,
                                StackDAO stackDAO,
                                HostDAO hostDAO,
                                ServiceComponentDesiredStateDAO serviceComponentDesiredStateDAO,
                                HostComponentStateDAO hostComponentStateDAO,
                                HostComponentDesiredStateDAO hostComponentDesiredStateDAO,
                                AmbariEventPublisher eventPublisher)

ServiceComponentHostImpl

public ServiceComponentHostImpl(ServiceComponent serviceComponent,
                                String hostName,
                                Clusters clusters,
                                StackDAO stackDAO,
                                HostDAO hostDAO,
                                ServiceComponentDesiredStateDAO serviceComponentDesiredStateDAO,
                                HostComponentStateDAO hostComponentStateDAO,
                                HostComponentDesiredStateDAO hostComponentDesiredStateDAO,
                                AmbariEventPublisher eventPublisher)

ServiceComponentHostImpl

public ServiceComponentHostImpl(ServiceComponent serviceComponent,
                                HostComponentStateEntity stateEntity,
                                HostComponentDesiredStateEntity desiredStateEntity,
                                Clusters clusters,
                                StackDAO stackDAO,
                                HostDAO hostDAO,
                                ServiceComponentDesiredStateDAO serviceComponentDesiredStateDAO,
                                HostComponentStateDAO hostComponentStateDAO,
                                HostComponentDesiredStateDAO hostComponentDesiredStateDAO,
                                AmbariEventPublisher eventPublisher)

Method Detail

getState

public State getState()

Specified by:

getState in interface ServiceComponentHost

setState

public void setState(State state)

Specified by:

setState in interface ServiceComponentHost

getVersion

public String getVersion()

Description copied from interface: ServiceComponentHost

Gets the version of the component.

Specified by:

getVersion in interface ServiceComponentHost

Returns:

component version

setVersion

public void setVersion(String version)
                throws org.apache.ambari.server.AmbariException

Description copied from interface: ServiceComponentHost

Sets the version of the component from the stack.

Specified by:

setVersion in interface ServiceComponentHost

Parameters:

version - component version (e.g. 2.2.0.0-2041)

Throws:

org.apache.ambari.server.AmbariException

setUpgradeState

public void setUpgradeState(UpgradeState upgradeState)

To be called during the upgrade of a specific Component in a host. The potential upgrade states are NONE (default), PENDING, IN_PROGRESS, FAILED. If the upgrade completes successfully, the upgradeState should be set back to NONE. If the upgrade fails, then the user can retry to set it back into PENDING or IN_PROGRESS. If the upgrade is aborted, then the upgradeState should be set back to NONE.

Specified by:

setUpgradeState in interface ServiceComponentHost

Parameters:

upgradeState - the upgrade state

getUpgradeState

public UpgradeState getUpgradeState()

Specified by:

getUpgradeState in interface ServiceComponentHost

Returns:

the upgrade state. Valid values: NONE - means that component is installed and good to go, no upgrade in progress IN_PROGRESS - means that component is being upgraded COMPLETE - means that component has reported a correct new version during upgrade FAILED - means that failed and component did not get upgraded VERSION_MISMATCH - means that component reported unexpected version

handleEvent

public void handleEvent(ServiceComponentHostEvent event)
                 throws InvalidStateTransitionException

Description copied from interface: ServiceComponentHost

Send a ServiceComponentHostState event to the StateMachine

Specified by:

handleEvent in interface ServiceComponentHost

Parameters:

event - Event to handle

Throws:

InvalidStateTransitionException

getServiceComponentName

public String getServiceComponentName()

Description copied from interface: ServiceComponentHost

Get the ServiceComponent this object maps to

Specified by:

getServiceComponentName in interface ServiceComponentHost

Returns:

Name of the ServiceComponent

getHostName

public String getHostName()

Description copied from interface: ServiceComponentHost

Get the Host this object maps to

Specified by:

getHostName in interface ServiceComponentHost

Returns:

Host's hostname

getPublicHostName

public String getPublicHostName()

Description copied from interface: ServiceComponentHost

Get the public host name this object maps to

Specified by:

getPublicHostName in interface ServiceComponentHost

Returns:

Host's public hostname

getHost

public Host getHost()

Description copied from interface: ServiceComponentHost

Get the Host this object maps to

Specified by:

getHost in interface ServiceComponentHost

Returns:

Host Object

getLastOpStartTime

public long getLastOpStartTime()

Returns:

the lastOpStartTime

setLastOpStartTime

public void setLastOpStartTime(long lastOpStartTime)

Parameters:

lastOpStartTime - the lastOpStartTime to set

getLastOpEndTime

public long getLastOpEndTime()

Returns:

the lastOpEndTime

setLastOpEndTime

public void setLastOpEndTime(long lastOpEndTime)

Parameters:

lastOpEndTime - the lastOpEndTime to set

getLastOpLastUpdateTime

public long getLastOpLastUpdateTime()

Returns:

the lastOpLastUpdateTime

setLastOpLastUpdateTime

public void setLastOpLastUpdateTime(long lastOpLastUpdateTime)

Parameters:

lastOpLastUpdateTime - the lastOpLastUpdateTime to set

getClusterId

public long getClusterId()

Description copied from interface: ServiceComponentHost

Get the Cluster that this object maps to

Specified by:

getClusterId in interface ServiceComponentHost

getServiceName

public String getServiceName()

Description copied from interface: ServiceComponentHost

Get the Service this object maps to

Specified by:

getServiceName in interface ServiceComponentHost

Returns:

Name of the Service

isClientComponent

public boolean isClientComponent()

Specified by:

isClientComponent in interface ServiceComponentHost

getDesiredState

public State getDesiredState()

Specified by:

getDesiredState in interface ServiceComponentHost

setDesiredState

public void setDesiredState(State state)

Specified by:

setDesiredState in interface ServiceComponentHost

getComponentAdminState

public HostComponentAdminState getComponentAdminState()

Specified by:

getComponentAdminState in interface ServiceComponentHost

setComponentAdminState

public void setComponentAdminState(HostComponentAdminState attribute)

Specified by:

setComponentAdminState in interface ServiceComponentHost

convertToResponse

public ServiceComponentHostResponse convertToResponse(Map<String,DesiredConfig> desiredConfigs)

Description copied from interface: ServiceComponentHost

Builds a ServiceComponentHostResponse.

Specified by:

convertToResponse in interface ServiceComponentHost

Parameters:

desiredConfigs - the desired configurations for the cluster. Obtaining these can be expensive and since this method operates on SCH's, it could be called 10,000's of times when generating cluster/host responses. Therefore, the caller should build these once and pass them in. If null, then this method will retrieve them at runtime, incurring a performance penality.

Returns:

convertToResponseStatusOnly

public ServiceComponentHostResponse convertToResponseStatusOnly(Map<String,DesiredConfig> desiredConfigs,
                                                                boolean collectStaleConfigsStatus)

Specified by:

convertToResponseStatusOnly in interface ServiceComponentHost

getClusterName

public String getClusterName()

Description copied from interface: ServiceComponentHost

Get the Cluster that this object maps to

Specified by:

getClusterName in interface ServiceComponentHost

debugDump

public void debugDump(StringBuilder sb)

Specified by:

debugDump in interface ServiceComponentHost

canBeRemoved

public boolean canBeRemoved()

Specified by:

canBeRemoved in interface ServiceComponentHost

delete

public void delete(DeleteHostComponentStatusMetaData deleteMetaData)

Specified by:

delete in interface ServiceComponentHost

removeEntities

protected void removeEntities()

getActualConfigs

public Map<String,HostConfig> getActualConfigs()

Description copied from interface: ServiceComponentHost

Gets the actual config tags, if known.

Specified by:

getActualConfigs in interface ServiceComponentHost

Returns:

the actual config map

getHostState

public HostState getHostState()

Specified by:

getHostState in interface ServiceComponentHost

isRecoveryEnabled

public boolean isRecoveryEnabled()

Description copied from interface: ServiceComponentHost

Get whether recovery is enabled for this component or not.

Specified by:

isRecoveryEnabled in interface ServiceComponentHost

Returns:

True or false.

setMaintenanceState

public void setMaintenanceState(MaintenanceState state)

Specified by:

setMaintenanceState in interface ServiceComponentHost

Parameters:

state - the maintenance state

getMaintenanceState

public MaintenanceState getMaintenanceState()

Specified by:

getMaintenanceState in interface ServiceComponentHost

Returns:

the maintenance state

setProcesses

public void setProcesses(List<Map<String,String>> procs)

Specified by:

setProcesses in interface ServiceComponentHost

Parameters:

procs - a list containing a map describing each process

getProcesses

public List<Map<String,String>> getProcesses()

Specified by:

getProcesses in interface ServiceComponentHost

Returns:

the list of maps describing each process

isRestartRequired

public boolean isRestartRequired()

Specified by:

isRestartRequired in interface ServiceComponentHost

Returns:

whether restart required

isRestartRequired

public boolean isRestartRequired(HostComponentDesiredStateEntity hostComponentDesiredStateEntity)

Specified by:

isRestartRequired in interface ServiceComponentHost

setRestartRequired

public void setRestartRequired(boolean restartRequired)

Specified by:

setRestartRequired in interface ServiceComponentHost

Parameters:

restartRequired - the restartRequired flag

setRestartRequiredWithoutEventPublishing

public boolean setRestartRequiredWithoutEventPublishing(boolean restartRequired)

Description copied from interface: ServiceComponentHost

Set restartRequired flag for appropriate HostComponentDesiredStateEntity

Specified by:

setRestartRequiredWithoutEventPublishing in interface ServiceComponentHost

Parameters:

restartRequired - the restartRequired flag.

Returns:

true when restartRequired flag was changed.

recalculateHostVersionState

public HostVersionEntity recalculateHostVersionState()
                                              throws org.apache.ambari.server.AmbariException

Updates an existing HostVersionEntity for the desired repository of this component, or create one if it doesn't exist.

Specified by:

recalculateHostVersionState in interface ServiceComponentHost

Returns:

Returns either the newly created or the updated Host Version Entity.

Throws:

org.apache.ambari.server.AmbariException

getDesiredStateEntity

public HostComponentDesiredStateEntity getDesiredStateEntity()

Gets the desired state entity for this ServiceComponentHost.

Specified by:

getDesiredStateEntity in interface ServiceComponentHost

Returns:

getServiceComponent

public ServiceComponent getServiceComponent()

Gets the service component.

Specified by:

getServiceComponent in interface ServiceComponentHost

Returns:

the service component (never null).

getDesiredStackId

public StackId getDesiredStackId()

Convenience method to get the desired stack id from the service component

Specified by:

getDesiredStackId in interface ServiceComponentHost

Returns:

the desired stack id