org.apache.ambari.server.agent.stomp

Class AgentHostDataHolder<T extends STOMPHostEvent & Hashable>

java.lang.Object

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

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

Type Parameters:

T - event with hash to control version

Direct Known Subclasses:

AgentConfigsHolder, AlertDefinitionsHolder, HostLevelParamsHolder

public abstract class AgentHostDataHolder<T extends STOMPHostEvent & Hashable>
extends AgentDataHolder<T>

Is used to saving and updating last version of event in host scope

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG

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

updateLock

Constructor Summary

Constructors

Constructor and Description
AgentHostDataHolder()

Method Summary

Modifier and Type	Method and Description
protected abstract T	getCurrentData(Long hostId)
Map<Long,T>	getData()
T	getData(Long hostId)
T	getUpdateIfChanged(String agentHash, Long hostId)
protected abstract T	handleUpdate(T current, T update)
T	initializeDataIfNeeded(Long hostId, boolean regenerateHash)
void	onHostRemoved(Long hostId) Remove data for the given host.
void	resetData(Long hostId) Reset data for the given host.
void	setData(T data, Long hostId)
protected void	setIdentifiersToEventUpdate(T update, T hostData)
void	updateData(T update) Apply an incremental update to the data (host-specific), and publish the event to listeners.

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

getEmptyData, getHash, getHash, isIdentifierValid, regenerateDataIdentifiers

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.slf4j.Logger LOG

Constructor Detail

AgentHostDataHolder

public AgentHostDataHolder()

Method Detail

getCurrentData

protected abstract T getCurrentData(Long hostId)
                             throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

handleUpdate

protected abstract T handleUpdate(T current,
                                  T update)
                           throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

getUpdateIfChanged

public T getUpdateIfChanged(String agentHash,
                            Long hostId)
                     throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

initializeDataIfNeeded

public T initializeDataIfNeeded(Long hostId,
                                boolean regenerateHash)
                         throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

updateData

public void updateData(T update)
                throws org.apache.ambari.server.AmbariException

Apply an incremental update to the data (host-specific), and publish the event to listeners.

Throws:

org.apache.ambari.server.AmbariException

setIdentifiersToEventUpdate

protected void setIdentifiersToEventUpdate(T update,
                                           T hostData)

resetData

public final void resetData(Long hostId)
                     throws org.apache.ambari.server.AmbariException

Reset data for the given host. Used if changes are complex and it's easier to re-create data from scratch.

Throws:

org.apache.ambari.server.AmbariException

onHostRemoved

public final void onHostRemoved(Long hostId)

Remove data for the given host.

getData

public Map<Long,T> getData()

getData

public T getData(Long hostId)

setData

public void setData(T data,
                    Long hostId)