org.apache.ambari.server.topology

Class PersistedStateImpl

java.lang.Object

org.apache.ambari.server.topology.PersistedStateImpl

All Implemented Interfaces:

PersistedState

@Singleton
public class PersistedStateImpl
extends Object
implements PersistedState

Implementation which uses Ambari Database DAO and Entity objects for persistence of topology related information.

Constructor Summary

Constructors

Constructor and Description
PersistedStateImpl()

Method Summary

Modifier and Type	Method and Description
Map<ClusterTopology,List<LogicalRequest>>	getAllRequests() Get all persisted requests.
LogicalRequest	getProvisionRequest(long clusterId) Returns provision request for a cluster
void	persistLogicalRequest(LogicalRequest logicalRequest, long topologyRequestId) Persist a logical request.
PersistedTopologyRequest	persistTopologyRequest(BaseClusterRequest request) Persist a topology request.
void	registerHostName(long hostRequestId, String hostName) Registeer a host with a host request.
void	registerInTopologyHostInfo(Host host)
void	registerPhysicalTask(long logicalTaskId, long physicalTaskId) Register a physical task with a logical task.
void	removeHostRequests(long logicalRequestId, Collection<HostRequest> hostRequests) Remove the given host requests (must belong to the same topology request), and also the topology request if it does not have any host requests left.
void	setHostRequestStatus(long hostRequestId, HostRoleStatus status, String message) Update the status of the given host request.

Methods inherited from class java.lang.Object

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

Constructor Detail

PersistedStateImpl

public PersistedStateImpl()

Method Detail

persistTopologyRequest

public PersistedTopologyRequest persistTopologyRequest(BaseClusterRequest request)

Description copied from interface: PersistedState

Persist a topology request.

Specified by:

persistTopologyRequest in interface PersistedState

Parameters:

request - topology request to persist

Returns:

a persisted topology request which is a wrapper around a TopologyRequest which adds an id that can be used to refer to the persisted entity

persistLogicalRequest

public void persistLogicalRequest(LogicalRequest logicalRequest,
                                  long topologyRequestId)

Description copied from interface: PersistedState

Persist a logical request.

Specified by:

persistLogicalRequest in interface PersistedState

Parameters:

logicalRequest - logical request to persist

topologyRequestId - the id of the associated topology request

removeHostRequests

public void removeHostRequests(long logicalRequestId,
                               Collection<HostRequest> hostRequests)

Description copied from interface: PersistedState

Remove the given host requests (must belong to the same topology request), and also the topology request if it does not have any host requests left.

Specified by:

removeHostRequests in interface PersistedState

setHostRequestStatus

public void setHostRequestStatus(long hostRequestId,
                                 HostRoleStatus status,
                                 String message)

Description copied from interface: PersistedState

Update the status of the given host request.

Specified by:

setHostRequestStatus in interface PersistedState

registerPhysicalTask

public void registerPhysicalTask(long logicalTaskId,
                                 long physicalTaskId)

Description copied from interface: PersistedState

Register a physical task with a logical task.

Specified by:

registerPhysicalTask in interface PersistedState

Parameters:

logicalTaskId - logical task id

physicalTaskId - physical task id

registerHostName

public void registerHostName(long hostRequestId,
                             String hostName)

Description copied from interface: PersistedState

Registeer a host with a host request.

Specified by:

registerHostName in interface PersistedState

Parameters:

hostRequestId - host request id

hostName - name of host being registered

registerInTopologyHostInfo

public void registerInTopologyHostInfo(Host host)

Specified by:

registerInTopologyHostInfo in interface PersistedState

getProvisionRequest

public LogicalRequest getProvisionRequest(long clusterId)

Description copied from interface: PersistedState

Returns provision request for a cluster

Specified by:

getProvisionRequest in interface PersistedState

Returns:

getAllRequests

public Map<ClusterTopology,List<LogicalRequest>> getAllRequests()

Description copied from interface: PersistedState

Get all persisted requests. This is used to replay all requests upon ambari startup.

Specified by:

getAllRequests in interface PersistedState

Returns:

map of cluster topology to list of logical requests