org.apache.ambari.server.agent.stomp

Class TopologyHolder

java.lang.Object

org.apache.ambari.server.agent.stomp.AgentDataHolder<T>

org.apache.ambari.server.agent.stomp.AgentClusterDataHolder<TopologyUpdateEvent>

org.apache.ambari.server.agent.stomp.TopologyHolder

public class TopologyHolder
extends AgentClusterDataHolder<TopologyUpdateEvent>

Field Summary

Fields inherited from class org.apache.ambari.server.agent.stomp.AgentClusterDataHolder

STOMPUpdatePublisher

Fields inherited from class org.apache.ambari.server.agent.stomp.AgentDataHolder

updateLock

Constructor Summary

Constructors

Constructor and Description
TopologyHolder(AmbariEventPublisher ambariEventPublisher)

Method Summary

Modifier and Type	Method and Description
TopologyUpdateEvent	getCurrentData() Is used during agent registering to provide base info about clusters topology.
protected TopologyUpdateEvent	getEmptyData()
TopologyUpdateEvent	getUpdateIfChanged(String agentHash)
protected boolean	handleUpdate(TopologyUpdateEvent update) Handle an incremental update to the data.
void	onClusterComponentsRepoUpdate(ClusterComponentsRepoChangedEvent clusterComponentsRepoChangedEvent)
boolean	updateData(TopologyUpdateEvent update) Template method to update the data.

Methods inherited from class org.apache.ambari.server.agent.stomp.AgentClusterDataHolder

getData, initializeDataIfNeeded

Methods inherited from class org.apache.ambari.server.agent.stomp.AgentDataHolder

getHash, getHash, isIdentifierValid, regenerateDataIdentifiers

Methods inherited from class java.lang.Object

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

Constructor Detail

TopologyHolder

@Inject
public TopologyHolder(AmbariEventPublisher ambariEventPublisher)

Method Detail

getUpdateIfChanged

public TopologyUpdateEvent getUpdateIfChanged(String agentHash)
                                       throws org.apache.ambari.server.AmbariException

Overrides:

getUpdateIfChanged in class AgentClusterDataHolder<TopologyUpdateEvent>

Throws:

org.apache.ambari.server.AmbariException

getCurrentData

public TopologyUpdateEvent getCurrentData()
                                   throws org.apache.ambari.server.AmbariException

Is used during agent registering to provide base info about clusters topology.

Specified by:

getCurrentData in class AgentClusterDataHolder<TopologyUpdateEvent>

Returns:

filled TopologyUpdateEvent with info about all components and hosts in all clusters

Throws:

org.apache.ambari.server.AmbariException

updateData

public boolean updateData(TopologyUpdateEvent update)
                   throws org.apache.ambari.server.AmbariException

Description copied from class: AgentClusterDataHolder

Template method to update the data.

Overrides:

updateData in class AgentClusterDataHolder<TopologyUpdateEvent>

Returns:

true if the update introduced any change

Throws:

org.apache.ambari.server.AmbariException

handleUpdate

protected boolean handleUpdate(TopologyUpdateEvent update)
                        throws org.apache.ambari.server.AmbariException

Description copied from class: AgentClusterDataHolder

Handle an incremental update to the data.

Specified by:

handleUpdate in class AgentClusterDataHolder<TopologyUpdateEvent>

Returns:

true if the update introduced any change

Throws:

org.apache.ambari.server.AmbariException

getEmptyData

protected TopologyUpdateEvent getEmptyData()

Specified by:

getEmptyData in class AgentDataHolder<TopologyUpdateEvent>

onClusterComponentsRepoUpdate

public void onClusterComponentsRepoUpdate(ClusterComponentsRepoChangedEvent clusterComponentsRepoChangedEvent)
                                   throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException