org.apache.ambari.server.state.host

Class HostImpl

java.lang.Object

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

All Implemented Interfaces:

Host

public class HostImpl
extends Object
implements Host

Constructor Summary

Constructors

Constructor and Description
HostImpl(HostEntity hostEntity, boolean persisted, com.google.inject.Injector injector)

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.
HostResponse	convertToResponse()
AgentVersion	getAgentVersion() Version of the Ambari Agent running on 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) Get a map of configType with all applicable config tags.
List<DiskInfo>	getDisksInfo() Get information on disks available on the host.
HostHealthStatus	getHealthStatus()
Map<String,String>	getHostAttributes() Get additional host attributes For example, public/hostname/IP for AWS
String	getHostName()
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	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	getOsInfo() Get the General OS information.
String	getOsType() Get the OS Type: RHEL5/RHEL6/CentOS5/...
int	getPhCpuCount()
String	getPublicHostName() Sets the public-facing host name.
String	getRackInfo()
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
void	importHostInfo(HostInfo hostInfo)
boolean	isPersisted() Shows if Host is persisted to database
void	persist() Save host to database and make all changes to be saved afterwards
void	refresh()
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	setHostName(String hostName)
void	setIPv4(String ip)
void	setIPv6(String ip)
void	setLastAgentEnv(AgentEnv env) Sets the latest agent environment that arrived in a heartbeat.
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	setPublicHostName(String hostName) Gets the public-facing host name.
void	setRackInfo(String rackInfo)
void	setState(HostState state) Set the State of the Host
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.

Methods inherited from class java.lang.Object

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

Constructor Detail

HostImpl

@Inject
public HostImpl(HostEntity hostEntity,
                        boolean persisted,
                        com.google.inject.Injector injector)

Method Detail

importHostInfo

public void importHostInfo(HostInfo hostInfo)

Specified by:

importHostInfo in interface Host

Parameters:

hostInfo -

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

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

setHostName

public void setHostName(String hostName)

Specified by:

setHostName in interface Host

Parameters:

hostName - the hostName to set

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: RHEL5/RHEL6/CentOS5/... 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

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

getHealthStatus

public HostHealthStatus getHealthStatus()

Specified by:

getHealthStatus in interface Host

Returns:

the healthStatus

setHealthStatus

public void setHealthStatus(HostHealthStatus healthStatus)

Specified by:

setHealthStatus in interface Host

Parameters:

healthStatus - the healthStatus 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

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

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

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

convertToResponse

public HostResponse convertToResponse()

Specified by:

convertToResponse in interface Host

isPersisted

public boolean isPersisted()

Shows if Host is persisted to database

Specified by:

isPersisted in interface Host

Returns:

true if persisted

persist

public void persist()

Save host to database and make all changes to be saved afterwards

Specified by:

persist in interface Host

refresh

public void refresh()

Specified by:

refresh 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)
                                             throws AmbariException

Get a map of configType with all applicable config tags.

Specified by:

getDesiredHostConfigs in interface Host

Parameters:

cluster -

Returns:

Map of configType -> HostConfig

Throws:

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