org.apache.ambari.server.agent

Class HeartbeatProcessor

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.apache.ambari.server.agent.HeartbeatProcessor

All Implemented Interfaces:

com.google.common.util.concurrent.Service

public class HeartbeatProcessor
extends com.google.common.util.concurrent.AbstractService

HeartbeatProcessor class is used for bulk processing data retrieved from agents in background

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Constructor Summary

Constructors

Constructor and Description
HeartbeatProcessor(Clusters clusterFsm, ActionManager am, HeartbeatMonitor heartbeatMonitor, com.google.inject.Injector injector)

Method Summary

Modifier and Type	Method and Description
void	addHeartbeat(HeartBeat heartBeat)
protected void	doStart()
protected void	doStop()
protected void	processAlerts(HeartBeat heartbeat) Extracts all of the Alerts from the heartbeat and fires AlertEvents for each one.
void	processAlerts(String hostname, List<Alert> alerts)
protected void	processCommandReports(HeartBeat heartbeat, long now) Process reports of tasks executed on agents
protected void	processCommandReports(List<CommandReport> reports, String hostName, Long now)
void	processHeartbeat(HeartBeat heartbeat) Incapsulates logic for processing data from agent heartbeat
protected void	processHostStatus(HeartBeat heartbeat) Update host status basing on components statuses
protected void	processHostStatus(List<ComponentStatus> componentStatuses, List<CommandReport> reports, String hostName)
protected void	processStatusReports(HeartBeat heartbeat) Process reports of status commands
void	processStatusReports(List<ComponentStatus> componentStatuses, String hostname) Process reports of status commands
void	processVersionReports(ComponentVersionReports versionReports, String hostname) Process reports of components versions

Methods inherited from class com.google.common.util.concurrent.AbstractService

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

HeartbeatProcessor

@Inject
public HeartbeatProcessor(Clusters clusterFsm,
                                  ActionManager am,
                                  HeartbeatMonitor heartbeatMonitor,
                                  com.google.inject.Injector injector)

Method Detail

doStart

protected void doStart()

Specified by:

doStart in class com.google.common.util.concurrent.AbstractService

doStop

protected void doStop()

Specified by:

doStop in class com.google.common.util.concurrent.AbstractService

addHeartbeat

public void addHeartbeat(HeartBeat heartBeat)

processHeartbeat

public void processHeartbeat(HeartBeat heartbeat)
                      throws org.apache.ambari.server.AmbariException

Incapsulates logic for processing data from agent heartbeat

Parameters:

heartbeat - Agent heartbeat object

Throws:

org.apache.ambari.server.AmbariException

processAlerts

protected void processAlerts(HeartBeat heartbeat)

Extracts all of the Alerts from the heartbeat and fires AlertEvents for each one. If there is a problem looking up the cluster, then alerts will not be processed.

Parameters:

heartbeat - the heartbeat to process.

processAlerts

public void processAlerts(String hostname,
                          List<Alert> alerts)

processHostStatus

protected void processHostStatus(HeartBeat heartbeat)
                          throws org.apache.ambari.server.AmbariException

Update host status basing on components statuses

Parameters:

heartbeat - heartbeat to process

Throws:

org.apache.ambari.server.AmbariException

processHostStatus

protected void processHostStatus(List<ComponentStatus> componentStatuses,
                                 List<CommandReport> reports,
                                 String hostName)
                          throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

processCommandReports

protected void processCommandReports(HeartBeat heartbeat,
                                     long now)
                              throws org.apache.ambari.server.AmbariException

Process reports of tasks executed on agents

Parameters:

heartbeat - heartbeat to process

now - cached current time

Throws:

org.apache.ambari.server.AmbariException

processCommandReports

protected void processCommandReports(List<CommandReport> reports,
                                     String hostName,
                                     Long now)
                              throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

processStatusReports

protected void processStatusReports(HeartBeat heartbeat)
                             throws org.apache.ambari.server.AmbariException

Process reports of status commands

Parameters:

heartbeat - heartbeat to process

Throws:

org.apache.ambari.server.AmbariException

processVersionReports

public void processVersionReports(ComponentVersionReports versionReports,
                                  String hostname)
                           throws org.apache.ambari.server.AmbariException

Process reports of components versions

Throws:

org.apache.ambari.server.AmbariException

processStatusReports

public void processStatusReports(List<ComponentStatus> componentStatuses,
                                 String hostname)
                          throws org.apache.ambari.server.AmbariException

Process reports of status commands

Throws:

org.apache.ambari.server.AmbariException