org.apache.ambari.server.state.host

Class HostImpl

java.lang.Object

org.apache.ambari.server.state.host.HostImpl

All Implemented Interfaces:

Comparable, Host

public class HostImpl
extends Object
implements Host

Constructor Summary

Constructors

Constructor and Description
HostImpl(HostEntity hostEntity, com.google.gson.Gson gson, HostDAO hostDAO, HostStateDAO hostStateDAO)

Method Summary

Modifier and Type	Method and Description
boolean	addDesiredConfig(long clusterId, boolean selected, String user, Config config) Adds a desired configuration to the host instance.
void	calculateHostStatus(Long clusterId)
int	compareTo(Object o)
HostResponse	convertToResponse()
boolean	equals(Object o)
AgentVersion	getAgentVersion() Version of the Ambari Agent running on the host
AgentVersion	getAgentVersion(HostStateEntity hostStateEntity) Gets version of the ambari agent running on the host.
List<HostVersionEntity>	getAllHostVersions() Get all of the HostVersionEntity objects for the host.
long	getAvailableMemBytes() Get the Amount of available memory for the Host.
int	getCpuCount()
Integer	getCurrentPingPort()
Map<String,DesiredConfig>	getDesiredConfigs(long clusterId) Gets all the selected configurations for the host.
Map<String,HostConfig>	getDesiredHostConfigs(Cluster cluster, Map<String,DesiredConfig> clusterDesiredConfigs) Get the desired configurations for the host including overrides
List<DiskInfo>	getDisksInfo() Get information on disks available on the host.
HostHealthStatus	getHealthStatus()
HostHealthStatus	getHealthStatus(HostStateEntity hostStateEntity) Gets the health status from host attributes
Map<String,String>	getHostAttributes() Get additional host attributes For example, public/hostname/IP for AWS
Map<String,String>	getHostAttributes(HostEntity hostEntity) Gets host attributes from host entity
HostEntity	getHostEntity()
Long	getHostId()
String	getHostName()
HostStateEntity	getHostStateEntity()
String	getIPv4() IPv4 assigned to the Host
String	getIPv6() IPv6 assigned to the Host
AgentEnv	getLastAgentEnv() Gets the latest agent environment that arrived in a heartbeat.
long	getLastAgentStartTime() Time the Ambari Agent was started.
long	getLastHeartbeatTime() Last time the Ambari Server received a heartbeat from the Host ( Unix timestamp )
long	getLastRegistrationTime() Last time the host registered with the Ambari Server ( Unix timestamp )
MaintenanceState	getMaintenanceState(long clusterId)
String	getOsArch() Get the OS Architecture.
String	getOsFamily() Get the os Family: redhat6: for centos6, rhel6, oraclelinux6 ..
String	getOsFamily(Map<String,String> hostAttributes) Gets the os family from host attributes
String	getOSFamilyFromHostAttributes(Map<String,String> hostAttributes)
String	getOsInfo() Get the General OS information.
String	getOsType() Get the OS Type: RHEL6/CentOS6/...
int	getPhCpuCount()
String	getPrefix() Get the prefix path of all logs
String	getPublicHostName() Sets the public-facing host name.
String	getRackInfo()
RecoveryReport	getRecoveryReport() Get detailed recovery report for the host
HostState	getState() Get Current Host State
String	getStatus() Get Current Host Status
long	getTimeInState() Get time spent in the current state i.e.
long	getTotalMemBytes() Get the Amount of physical memory for the Host.
void	handleEvent(HostEvent event) Send an event to the Host's StateMachine
boolean	hasComponentsAdvertisingVersions(StackId stackId) Gets whether this host has components which advertise their version.
int	hashCode()
void	importHostInfo(HostInfo hostInfo)
boolean	isRepositoryVersionCorrect(RepositoryVersionEntity repositoryVersion) Gets whether all host components whose desired repository version matches the repository version specified have reported the correct version and are no longer upgrading.
void	setAgentVersion(AgentVersion agentVersion)
void	setAvailableMemBytes(long availableMemBytes) Set the Amount of available memory for the Host.
void	setCpuCount(int cpuCount)
void	setCurrentPingPort(Integer currentPingPort)
void	setDisksInfo(List<DiskInfo> disksInfo)
void	setHealthStatus(HostHealthStatus healthStatus)
void	setHostAttributes(Map<String,String> hostAttributes)
void	setIPv4(String ip)
void	setIPv6(String ip)
void	setLastAgentEnv(AgentEnv env) Sets the latest agent environment that arrived in a heartbeat.
void	setLastAgentStartTime(long lastAgentStartTime)
void	setLastHeartbeatTime(long lastHeartbeatTime)
void	setLastRegistrationTime(long lastRegistrationTime)
void	setMaintenanceState(long clusterId, MaintenanceState state) Sets the maintenance state for the host.
void	setOsArch(String osArch)
void	setOsInfo(String osInfo)
void	setOsType(String osType)
void	setPhCpuCount(int phCpuCount)
void	setPrefix(String prefix) Set the prefix path of all logs of the host
void	setPublicHostName(String hostName) Gets the public-facing host name.
void	setRackInfo(String rackInfo)
void	setRecoveryReport(RecoveryReport recoveryReport) Set detailed recovery report for the host
void	setState(HostState state) Set the State of the Host
void	setStateMachineState(HostState state) Set state of host's state machine.
void	setStatus(String status) Set the Status of the Host
void	setTimeInState(long timeInState)
void	setTotalMemBytes(long totalMemBytes) Set the Amount of physical memory for the Host.
void	updateHost(HostRegistrationRequestEvent e)
void	updateHostTimestamps(HostRegistrationRequestEvent e)

Methods inherited from class java.lang.Object

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

Constructor Detail

HostImpl

@Inject
public HostImpl(HostEntity hostEntity,
                        com.google.gson.Gson gson,
                        HostDAO hostDAO,
                        HostStateDAO hostStateDAO)

Method Detail

compareTo

public int compareTo(Object o)

Specified by:

compareTo in interface Comparable

importHostInfo

public void importHostInfo(HostInfo hostInfo)

Specified by:

importHostInfo in interface Host

Parameters:

hostInfo - the host information

setLastAgentEnv

public void setLastAgentEnv(AgentEnv env)

Description copied from interface: Host

Sets the latest agent environment that arrived in a heartbeat.

Specified by:

setLastAgentEnv in interface Host

getLastAgentEnv

public AgentEnv getLastAgentEnv()

Description copied from interface: Host

Gets the latest agent environment that arrived in a heartbeat.

Specified by:

getLastAgentEnv in interface Host

getState

public HostState getState()

Description copied from interface: Host

Get Current Host State

Specified by:

getState in interface Host

Returns:

HostState

setState

public void setState(HostState state)

Description copied from interface: Host

Set the State of the Host

Specified by:

setState in interface Host

Parameters:

state - Host State

setStateMachineState

public void setStateMachineState(HostState state)

Description copied from interface: Host

Set state of host's state machine.

Specified by:

setStateMachineState in interface Host

handleEvent

public void handleEvent(HostEvent event)
                 throws InvalidStateTransitionException

Description copied from interface: Host

Send an event to the Host's StateMachine

Specified by:

handleEvent in interface Host

Parameters:

event - HostEvent

Throws:

InvalidStateTransitionException

getHostName

public String getHostName()

Specified by:

getHostName in interface Host

Returns:

the hostName

getHostId

public Long getHostId()

Specified by:

getHostId in interface Host

Returns:

host id

getCurrentPingPort

public Integer getCurrentPingPort()

Specified by:

getCurrentPingPort in interface Host

Returns:

the currentPingPort

setCurrentPingPort

public void setCurrentPingPort(Integer currentPingPort)

Specified by:

setCurrentPingPort in interface Host

Parameters:

currentPingPort - the currentPingPort to set

setPublicHostName

public void setPublicHostName(String hostName)

Description copied from interface: Host

Gets the public-facing host name.

Specified by:

setPublicHostName in interface Host

getPublicHostName

public String getPublicHostName()

Description copied from interface: Host

Sets the public-facing host name.

Specified by:

getPublicHostName in interface Host

getIPv4

public String getIPv4()

Description copied from interface: Host

IPv4 assigned to the Host

Specified by:

getIPv4 in interface Host

Returns:

the ip or null if no IPv4 interface

setIPv4

public void setIPv4(String ip)

Specified by:

setIPv4 in interface Host

Parameters:

ip - the ip to set

getIPv6

public String getIPv6()

Description copied from interface: Host

IPv6 assigned to the Host

Specified by:

getIPv6 in interface Host

Returns:

the ip or null if no IPv6 interface

setIPv6

public void setIPv6(String ip)

Specified by:

setIPv6 in interface Host

Parameters:

ip - the ip to set

getCpuCount

public int getCpuCount()

Specified by:

getCpuCount in interface Host

Returns:

the cpuCount

setCpuCount

public void setCpuCount(int cpuCount)

Specified by:

setCpuCount in interface Host

Parameters:

cpuCount - the cpuCount to set

getPhCpuCount

public int getPhCpuCount()

Specified by:

getPhCpuCount in interface Host

Returns:

the physical cpu cores

setPhCpuCount

public void setPhCpuCount(int phCpuCount)

Specified by:

setPhCpuCount in interface Host

Parameters:

phCpuCount - the physical cpu cores to set

getTotalMemBytes

public long getTotalMemBytes()

Description copied from interface: Host

Get the Amount of physical memory for the Host.

Specified by:

getTotalMemBytes in interface Host

Returns:

the totalMemBytes

setTotalMemBytes

public void setTotalMemBytes(long totalMemBytes)

Description copied from interface: Host

Set the Amount of physical memory for the Host.

Specified by:

setTotalMemBytes in interface Host

Parameters:

totalMemBytes - the totalMemBytes to set

getAvailableMemBytes

public long getAvailableMemBytes()

Description copied from interface: Host

Get the Amount of available memory for the Host. In most cases, available should be same as total unless the agent on the host is configured to not use all available memory

Specified by:

getAvailableMemBytes in interface Host

Returns:

the availableMemBytes

setAvailableMemBytes

public void setAvailableMemBytes(long availableMemBytes)

Description copied from interface: Host

Set the Amount of available memory for the Host.

Specified by:

setAvailableMemBytes in interface Host

Parameters:

availableMemBytes - the availableMemBytes to set

getOsArch

public String getOsArch()

Description copied from interface: Host

Get the OS Architecture. i386, x86_64, etc.

Specified by:

getOsArch in interface Host

Returns:

the osArch

setOsArch

public void setOsArch(String osArch)

Specified by:

setOsArch in interface Host

Parameters:

osArch - the osArch to set

getOsInfo

public String getOsInfo()

Description copied from interface: Host

Get the General OS information. uname -a, /etc/*-release dump

Specified by:

getOsInfo in interface Host

Returns:

the osInfo

setOsInfo

public void setOsInfo(String osInfo)

Specified by:

setOsInfo in interface Host

Parameters:

osInfo - the osInfo to set

getOsType

public String getOsType()

Description copied from interface: Host

Get the OS Type: RHEL6/CentOS6/... Defined and match-able OS type

Specified by:

getOsType in interface Host

Returns:

the osType

setOsType

public void setOsType(String osType)

Specified by:

setOsType in interface Host

Parameters:

osType - the osType to set

getOsFamily

public String getOsFamily()

Description copied from interface: Host

Get the os Family: redhat6: for centos6, rhel6, oraclelinux6 .. ubuntu12 : for ubuntu12 suse11: for sles11, suse11 .. suse12: for suse12, sles12 ..

Specified by:

getOsFamily in interface Host

Returns:

the osFamily

getOsFamily

public String getOsFamily(Map<String,String> hostAttributes)

Description copied from interface: Host

Gets the os family from host attributes

Specified by:

getOsFamily in interface Host

Parameters:

hostAttributes - host attributes

Returns:

the os family for host

getOSFamilyFromHostAttributes

public String getOSFamilyFromHostAttributes(Map<String,String> hostAttributes)

Specified by:

getOSFamilyFromHostAttributes in interface Host

getDisksInfo

public List<DiskInfo> getDisksInfo()

Description copied from interface: Host

Get information on disks available on the host.

Specified by:

getDisksInfo in interface Host

Returns:

the disksInfo

setDisksInfo

public void setDisksInfo(List<DiskInfo> disksInfo)

Specified by:

setDisksInfo in interface Host

Parameters:

disksInfo - the disksInfo to set

getRecoveryReport

public RecoveryReport getRecoveryReport()

Description copied from interface: Host

Get detailed recovery report for the host

Specified by:

getRecoveryReport in interface Host

Returns:

setRecoveryReport

public void setRecoveryReport(RecoveryReport recoveryReport)

Description copied from interface: Host

Set detailed recovery report for the host

Specified by:

setRecoveryReport in interface Host

getHealthStatus

public HostHealthStatus getHealthStatus()

Specified by:

getHealthStatus in interface Host

Returns:

the healthStatus

getHealthStatus

public HostHealthStatus getHealthStatus(HostStateEntity hostStateEntity)

Description copied from interface: Host

Gets the health status from host attributes

Specified by:

getHealthStatus in interface Host

Parameters:

hostStateEntity - host attributes

Returns:

the health status

setHealthStatus

public void setHealthStatus(HostHealthStatus healthStatus)

Specified by:

setHealthStatus in interface Host

Parameters:

healthStatus - the healthStatus to set

getPrefix

public String getPrefix()

Description copied from interface: Host

Get the prefix path of all logs

Specified by:

getPrefix in interface Host

Returns:

prefix

setPrefix

public void setPrefix(String prefix)

Description copied from interface: Host

Set the prefix path of all logs of the host

Specified by:

setPrefix in interface Host

Parameters:

prefix - the prefix path to set

getHostAttributes

public Map<String,String> getHostAttributes()

Description copied from interface: Host

Get additional host attributes For example, public/hostname/IP for AWS

Specified by:

getHostAttributes in interface Host

Returns:

the hostAttributes

getHostAttributes

public Map<String,String> getHostAttributes(HostEntity hostEntity)

Description copied from interface: Host

Gets host attributes from host entity

Specified by:

getHostAttributes in interface Host

Parameters:

hostEntity - host entity

Returns:

the host attributes

setHostAttributes

public void setHostAttributes(Map<String,String> hostAttributes)

Specified by:

setHostAttributes in interface Host

Parameters:

hostAttributes - the hostAttributes to set

getRackInfo

public String getRackInfo()

Specified by:

getRackInfo in interface Host

Returns:

the rackInfo

setRackInfo

public void setRackInfo(String rackInfo)

Specified by:

setRackInfo in interface Host

Parameters:

rackInfo - the rackInfo to set

getLastRegistrationTime

public long getLastRegistrationTime()

Description copied from interface: Host

Last time the host registered with the Ambari Server ( Unix timestamp )

Specified by:

getLastRegistrationTime in interface Host

Returns:

the lastRegistrationTime

setLastRegistrationTime

public void setLastRegistrationTime(long lastRegistrationTime)

Specified by:

setLastRegistrationTime in interface Host

Parameters:

lastRegistrationTime - the lastRegistrationTime to set

getLastHeartbeatTime

public long getLastHeartbeatTime()

Description copied from interface: Host

Last time the Ambari Server received a heartbeat from the Host ( Unix timestamp )

Specified by:

getLastHeartbeatTime in interface Host

Returns:

the lastHeartbeatTime

setLastHeartbeatTime

public void setLastHeartbeatTime(long lastHeartbeatTime)

Specified by:

setLastHeartbeatTime in interface Host

Parameters:

lastHeartbeatTime - the lastHeartbeatTime to set

getLastAgentStartTime

public long getLastAgentStartTime()

Description copied from interface: Host

Time the Ambari Agent was started. ( Unix timestamp )

Specified by:

getLastAgentStartTime in interface Host

Returns:

the lastOnAgentStartRegistrationTime

setLastAgentStartTime

public void setLastAgentStartTime(long lastAgentStartTime)

Specified by:

setLastAgentStartTime in interface Host

Parameters:

lastAgentStartTime - the lastAgentStartTime to set

getAgentVersion

public AgentVersion getAgentVersion()

Description copied from interface: Host

Version of the Ambari Agent running on the host

Specified by:

getAgentVersion in interface Host

Returns:

the agentVersion

getAgentVersion

public AgentVersion getAgentVersion(HostStateEntity hostStateEntity)

Description copied from interface: Host

Gets version of the ambari agent running on the host.

Specified by:

getAgentVersion in interface Host

Parameters:

hostStateEntity - host state entity

Returns:

the agentVersion

setAgentVersion

public void setAgentVersion(AgentVersion agentVersion)

Specified by:

setAgentVersion in interface Host

Parameters:

agentVersion - the agentVersion to set

getTimeInState

public long getTimeInState()

Description copied from interface: Host

Get time spent in the current state i.e. the time since last state change.

Specified by:

getTimeInState in interface Host

Returns:

Time spent in current state.

setTimeInState

public void setTimeInState(long timeInState)

Specified by:

setTimeInState in interface Host

Parameters:

timeInState - the timeInState to set

getStatus

public String getStatus()

Description copied from interface: Host

Get Current Host Status

Specified by:

getStatus in interface Host

Returns:

String

setStatus

public void setStatus(String status)

Description copied from interface: Host

Set the Status of the Host

Specified by:

setStatus in interface Host

Parameters:

status - Host Status

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

convertToResponse

public HostResponse convertToResponse()

Specified by:

convertToResponse in interface Host

addDesiredConfig

public boolean addDesiredConfig(long clusterId,
                                boolean selected,
                                String user,
                                Config config)

Description copied from interface: Host

Adds a desired configuration to the host instance.

Specified by:

addDesiredConfig in interface Host

Parameters:

clusterId - the cluster id that the config applies to

selected - true if the configuration is selected. Applies only to remove the override, otherwise this value should always be true.

user - the user making the change for audit purposes

config - the configuration object

Returns:

true if the config was added, or false if the config is already set as the current

getDesiredConfigs

public Map<String,DesiredConfig> getDesiredConfigs(long clusterId)

Description copied from interface: Host

Gets all the selected configurations for the host. return a map of type-to-DesiredConfig instances.

Specified by:

getDesiredConfigs in interface Host

getDesiredHostConfigs

public Map<String,HostConfig> getDesiredHostConfigs(Cluster cluster,
                                                    Map<String,DesiredConfig> clusterDesiredConfigs)
                                             throws org.apache.ambari.server.AmbariException

Get the desired configurations for the host including overrides

Specified by:

getDesiredHostConfigs in interface Host

clusterDesiredConfigs - the desired configurations for the cluster. Obtaining these can be expensive and since this method operates on hosts, it could be called 1,000's of times when generating 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:

Throws:

org.apache.ambari.server.AmbariException

setMaintenanceState

public void setMaintenanceState(long clusterId,
                                MaintenanceState state)

Description copied from interface: Host

Sets the maintenance state for the host.

Specified by:

setMaintenanceState in interface Host

Parameters:

clusterId - the cluster id

state - the state

getMaintenanceState

public MaintenanceState getMaintenanceState(long clusterId)

Specified by:

getMaintenanceState in interface Host

Parameters:

clusterId - the cluster id

Returns:

the maintenance state

getAllHostVersions

public List<HostVersionEntity> getAllHostVersions()

Get all of the HostVersionEntity objects for the host.

Specified by:

getAllHostVersions in interface Host

Returns:

all of the HostVersionEntity objects for the host

getHostEntity

public HostEntity getHostEntity()

Specified by:

getHostEntity in interface Host

getHostStateEntity

public HostStateEntity getHostStateEntity()

hasComponentsAdvertisingVersions

public boolean hasComponentsAdvertisingVersions(StackId stackId)
                                         throws org.apache.ambari.server.AmbariException

Gets whether this host has components which advertise their version.

Specified by:

hasComponentsAdvertisingVersions in interface Host

Parameters:

stackId - the version of the stack to use when checking version advertise-ability.

Returns:

true if at least 1 component on this host advertises its version.

Throws:

org.apache.ambari.server.AmbariException - if there is a problem retrieving the component from the stack.

See Also:

ComponentInfo.isVersionAdvertised()

calculateHostStatus

public void calculateHostStatus(Long clusterId)
                         throws org.apache.ambari.server.AmbariException

Specified by:

calculateHostStatus in interface Host

Throws:

org.apache.ambari.server.AmbariException

updateHost

public void updateHost(HostRegistrationRequestEvent e)

updateHostTimestamps

public void updateHostTimestamps(HostRegistrationRequestEvent e)

isRepositoryVersionCorrect

public boolean isRepositoryVersionCorrect(RepositoryVersionEntity repositoryVersion)
                                   throws org.apache.ambari.server.AmbariException

Gets whether all host components whose desired repository version matches the repository version specified have reported the correct version and are no longer upgrading.

Specified by:

isRepositoryVersionCorrect in interface Host

Parameters:

repositoryVersion - the repository version to check for (not null).

Returns:

true if all components on this host have checked in with the correct version if their desired repository matches the one specified.

Throws:

org.apache.ambari.server.AmbariException